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 entry : icebergProperty.getDfsProperties().entrySet()) { + conf.set(entry.getKey(), entry.getValue()); + } hiveCatalog.setConf(conf); // initialize hive catalog Map catalogProperties = new HashMap<>();