Skip to content

Commit 85b10cd

Browse files
committed
#AI commit# CC: HADOOP_CONF查询Hadoop配置不再依赖目标表存在性,autoCreateTable表不存在时仍按库路径或仓库路径获取配置 / HADOOP_CONF no longer depends on target table existence; still fetch Hadoop config by db or warehouse path when autoCreateTable table is absent
1 parent 661e33a commit 85b10cd

1 file changed

Lines changed: 0 additions & 7 deletions

File tree

  • exchangis-job/exchangis-job-server/src/main/java/com/webank/wedatasphere/exchangis/job/server/builder/transform/mappings

exchangis-job/exchangis-job-server/src/main/java/com/webank/wedatasphere/exchangis/job/server/builder/transform/mappings/HiveDataxParamsMapping.java

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -294,13 +294,6 @@ private enum Type {
294294
uri = PatternInjectUtils.inject(HIVE_WAREHOUSE_PATTERN.getValue(),
295295
Collections.singletonMap("user", Objects.nonNull(userName) ? userName : ""));
296296
}
297-
Boolean tableExists = TABLE_EXISTS.getValue(paramSet);
298-
// 表确实不存在(autoCreateTable 开启时主动判断)→ 走自动建表时返回空 hadoop 配置,不再查询元数据
299-
if (Boolean.FALSE.equals(tableExists)) {
300-
debug("Table not exists for uri [{}] (autoCreateTable=true, return empty hadoop config)", uri);
301-
return new HashMap<>();
302-
}
303-
// tableExists == null(autoCreateTable 关闭)或 tableExists == true(表存在):正常查询,异常照常抛出
304297
try {
305298
// TODO get the other hdfs cluster with tab
306299
return Objects.requireNonNull(getBean(MetadataInfoService.class)).getLocalHdfsInfo(uri);

0 commit comments

Comments
 (0)