This is an automated email from the ASF dual-hosted git repository. codope pushed a commit to branch release-0.12.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 6875fe43d02f74777726dfce0a332b176667eef2 Author: 5herhom <[email protected]> AuthorDate: Tue Aug 2 14:29:05 2022 +0800 [HUDI-4510] Repair config "hive_sync.metastore.uris" in flink sql hive schema sync is not effective (#6257) --- .../src/main/java/org/apache/hudi/sink/utils/HiveSyncContext.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/HiveSyncContext.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/HiveSyncContext.java index 25b6cfcff3..d2f56d9a3e 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/HiveSyncContext.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/HiveSyncContext.java @@ -84,6 +84,9 @@ public class HiveSyncContext { org.apache.hadoop.conf.Configuration hadoopConf = HadoopConfigurations.getHadoopConf(conf); HiveConf hiveConf = new HiveConf(); hiveConf.addResource(serConf.get()); + if (!FlinkOptions.isDefaultValueDefined(conf, FlinkOptions.HIVE_SYNC_METASTORE_URIS)) { + hadoopConf.set(HiveConf.ConfVars.METASTOREURIS.varname, conf.getString(FlinkOptions.HIVE_SYNC_METASTORE_URIS)); + } hiveConf.addResource(hadoopConf); return new HiveSyncContext(props, hiveConf); }
