(paimon) branch master updated: [hive] Fix load default hadoop config (#3433)

[lzljs3620320]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new a9a09f503 [hive] Fix load default hadoop config (#3433)
a9a09f503 is described below

commit a9a09f503efbc3a55edeb3a0560342d1f7a89a89
Author: wgcn <1026688...@qq.com>
AuthorDate: Thu May 30 13:46:55 2024 +0800

    [hive] Fix load default hadoop config (#3433)
---
 .../src/main/java/org/apache/paimon/hive/utils/HiveUtils.java    | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/utils/HiveUtils.java
 
b/paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/utils/HiveUtils.java
index 4ecd32b74..789879b35 100644
--- 
a/paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/utils/HiveUtils.java
+++ 
b/paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/utils/HiveUtils.java
@@ -47,6 +47,7 @@ import java.util.stream.Collectors;
 
 import static org.apache.paimon.options.OptionsUtils.PAIMON_PREFIX;
 import static 
org.apache.paimon.options.OptionsUtils.convertToPropertiesPrefixKey;
+import static org.apache.paimon.utils.HadoopUtils.HADOOP_LOAD_DEFAULT_CONFIG;
 
 /** Utils for create {@link FileStoreTable} and {@link Predicate}. */
 public class HiveUtils {
@@ -54,7 +55,13 @@ public class HiveUtils {
     public static FileStoreTable createFileStoreTable(JobConf jobConf) {
         Options options = extractCatalogConfig(jobConf);
         options.set(CoreOptions.PATH, 
LocationKeyExtractor.getPaimonLocation(jobConf));
-        CatalogContext catalogContext = CatalogContext.create(options, 
jobConf);
+
+        CatalogContext catalogContext;
+        if (options.get(HADOOP_LOAD_DEFAULT_CONFIG)) {
+            catalogContext = CatalogContext.create(options, jobConf);
+        } else {
+            catalogContext = CatalogContext.create(options);
+        }
         return FileStoreTableFactory.create(catalogContext);
     }