(hudi) branch master updated: fix: modify the incorrect Hive configuration in hoodie hive catalog (#18365)

[wombatukun]

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

wombatukun 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 941ae6200078 fix: modify the incorrect Hive configuration in hoodie 
hive catalog (#18365)
941ae6200078 is described below

commit 941ae620007886855da2614d0a30092fc5c33efe
Author: YangXiao <919869...@qq.com>
AuthorDate: Mon Mar 23 10:02:10 2026 +0800

    fix: modify the incorrect Hive configuration in hoodie hive catalog (#18365)
---
 .../org/apache/hudi/table/catalog/HoodieHiveCatalog.java    | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieHiveCatalog.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieHiveCatalog.java
index 7d0d7570febb..0ac03678711f 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieHiveCatalog.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieHiveCatalog.java
@@ -32,6 +32,7 @@ import org.apache.hudi.common.util.ValidationUtils;
 import org.apache.hudi.common.util.collection.Pair;
 import org.apache.hudi.config.HoodieIndexConfig;
 import org.apache.hudi.configuration.FlinkOptions;
+import org.apache.hudi.configuration.HadoopConfigurations;
 import org.apache.hudi.configuration.OptionsResolver;
 import org.apache.hudi.exception.HoodieCatalogException;
 import org.apache.hudi.exception.HoodieMetadataException;
@@ -568,14 +569,14 @@ public class HoodieHiveCatalog extends AbstractCatalog {
       properties.put(HoodieIndexConfig.INDEX_TYPE.key(), 
properties.get(FlinkOptions.INDEX_TYPE.key()));
     }
     properties.remove(FlinkOptions.INDEX_TYPE.key());
-    if (hiveConf.get("hive.metastore.uris") != null) {
-      properties.put("hadoop.hive.metastore.uris", 
hiveConf.get("hive.metastore.uris"));
+    if (hiveConf.get(HiveConf.ConfVars.METASTOREURIS.varname) != null) {
+      properties.put(HadoopConfigurations.HADOOP_PREFIX + 
HiveConf.ConfVars.METASTOREURIS.varname, 
hiveConf.get(HiveConf.ConfVars.METASTOREURIS.varname));
     }
-    if (hiveConf.get("hive.metastore.sasl.enabled") != null) {
-      properties.put("hadoop.hive.metastore.sasl.enabled", 
hiveConf.get("hive.metastore.sasl.enabled"));
+    if (hiveConf.get(HiveConf.ConfVars.METASTORE_USE_THRIFT_SASL.varname) != 
null) {
+      properties.put(HadoopConfigurations.HADOOP_PREFIX + 
HiveConf.ConfVars.METASTORE_USE_THRIFT_SASL.varname, 
hiveConf.get(HiveConf.ConfVars.METASTORE_USE_THRIFT_SASL.varname));
     }
-    if (hiveConf.get("hive.metastore.kerberos.principle") != null) {
-      properties.put("hadoop.hive.metastore.kerberos.principle", 
hiveConf.get("hive.metastore.kerberos.principle"));
+    if (hiveConf.get(HiveConf.ConfVars.METASTORE_KERBEROS_PRINCIPAL.varname) 
!= null) {
+      properties.put(HadoopConfigurations.HADOOP_PREFIX + 
HiveConf.ConfVars.METASTORE_KERBEROS_PRINCIPAL.varname, 
hiveConf.get(HiveConf.ConfVars.METASTORE_KERBEROS_PRINCIPAL.varname));
     }
 
     if (external) {