You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by wo...@apache.org on 2026/03/23 02:02:17 UTC
(hudi) branch master updated: fix: modify the incorrect Hive configuration in hoodie hive catalog (#18365)
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 <91...@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) {