Skip to content

Commit 84d195d

Browse files
authored
[HUDI-4510] Repair config "hive_sync.metastore.uris" in flink sql hive schema sync is not effective (#6257)
1 parent 251b63e commit 84d195d

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/HiveSyncContext.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -84,6 +84,9 @@ public static HiveSyncContext create(Configuration conf, SerializableConfigurati
8484
org.apache.hadoop.conf.Configuration hadoopConf = HadoopConfigurations.getHadoopConf(conf);
8585
HiveConf hiveConf = new HiveConf();
8686
hiveConf.addResource(serConf.get());
87+
if (!FlinkOptions.isDefaultValueDefined(conf, FlinkOptions.HIVE_SYNC_METASTORE_URIS)) {
88+
hadoopConf.set(HiveConf.ConfVars.METASTOREURIS.varname, conf.getString(FlinkOptions.HIVE_SYNC_METASTORE_URIS));
89+
}
8790
hiveConf.addResource(hadoopConf);
8891
return new HiveSyncContext(props, hiveConf);
8992
}

0 commit comments

Comments
 (0)