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

yiguolei pushed a commit to branch dev-1.1.2
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/dev-1.1.2 by this push:
     new 6c03dfb898 [Bug](external iceberg table)Fix iceberg on ha-hdfs unknown 
hostname bugFix iceberg on ha-hdfs unknown hostname bug. (#11872)
6c03dfb898 is described below

commit 6c03dfb89855da1d5c90b677c4c80db072227660
Author: Jibing-Li <64681310+jibing...@users.noreply.github.com>
AuthorDate: Thu Aug 18 08:56:07 2022 +0800

    [Bug](external iceberg table)Fix iceberg on ha-hdfs unknown hostname bugFix 
iceberg on ha-hdfs unknown hostname bug. (#11872)
---
 .../main/java/org/apache/doris/external/iceberg/HiveCatalog.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/external/iceberg/HiveCatalog.java 
b/fe/fe-core/src/main/java/org/apache/doris/external/iceberg/HiveCatalog.java
index 21a3db8ddd..fe73aa760d 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/external/iceberg/HiveCatalog.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/external/iceberg/HiveCatalog.java
@@ -19,6 +19,7 @@ package org.apache.doris.external.iceberg;
 
 import org.apache.doris.catalog.IcebergProperty;
 import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hdfs.HdfsConfiguration;
 import org.apache.iceberg.Table;
 import org.apache.iceberg.catalog.Namespace;
 import org.apache.iceberg.catalog.TableIdentifier;
@@ -44,7 +45,10 @@ public class HiveCatalog implements IcebergCatalog {
     @Override
     public void initialize(IcebergProperty icebergProperty) {
         // set hadoop conf
-        Configuration conf = new Configuration();
+        Configuration conf = new HdfsConfiguration();
+        for (Map.Entry<String, String> entry : 
icebergProperty.getDfsProperties().entrySet()) {
+            conf.set(entry.getKey(), entry.getValue());
+        }
         hiveCatalog.setConf(conf);
         // initialize hive catalog
         Map<String, String> catalogProperties = new HashMap<>();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to