This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 790a1d681f [Bug](external iceberg table)Fix iceberg on ha-hdfs unknown
hostname bug. #11844
790a1d681f is described below
commit 790a1d681f6f99b9996ec6d9a95c0ad07fe80c1b
Author: Jibing-Li <[email protected]>
AuthorDate: Wed Aug 17 16:21:30 2022 +0800
[Bug](external iceberg table)Fix iceberg on ha-hdfs unknown hostname bug.
#11844
---
.../src/main/java/org/apache/doris/external/iceberg/HiveCatalog.java | 3 +++
1 file changed, 3 insertions(+)
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 9a4e4f0e99..90eb013b68 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
@@ -47,6 +47,9 @@ public class HiveCatalog implements IcebergCatalog {
public void initialize(IcebergProperty icebergProperty) {
// set hadoop conf
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: [email protected]
For additional commands, e-mail: [email protected]
