[hudi] branch master updated: [HUDI-4510] Repair config "hive_sync.metastore.uris" in flink sql hive schema sync is not effective (#6257)

[danny0405]

This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 84d195d4d4 [HUDI-4510] Repair config "hive_sync.metastore.uris" in 
flink sql hive schema sync is not effective (#6257)
84d195d4d4 is described below

commit 84d195d4d4fbb1ca915d03999c704a910b6588fc
Author: 5herhom <35916131+5her...@users.noreply.github.com>
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);
   }