diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergHMSExternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergHMSExternalCatalog.java index 221aed4cd8c1d7..34e6f0c187e5ba 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergHMSExternalCatalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergHMSExternalCatalog.java @@ -24,7 +24,6 @@ import org.apache.iceberg.CatalogProperties; import org.apache.iceberg.hive.HiveCatalog; -import java.util.HashMap; import java.util.Map; public class IcebergHMSExternalCatalog extends IcebergExternalCatalog { @@ -42,7 +41,7 @@ protected void initCatalog() { HiveCatalog hiveCatalog = new org.apache.iceberg.hive.HiveCatalog(); hiveCatalog.setConf(getConfiguration()); // initialize hive catalog - Map catalogProperties = new HashMap<>(); + Map catalogProperties = catalogProperty.getProperties(); String metastoreUris = catalogProperty.getOrDefault(HMSProperties.HIVE_METASTORE_URIS, ""); catalogProperties.put(CatalogProperties.URI, metastoreUris); hiveCatalog.initialize(icebergCatalogType, catalogProperties); diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergHadoopExternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergHadoopExternalCatalog.java index e86bdd61369f59..01eee31d3b08d3 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergHadoopExternalCatalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergHadoopExternalCatalog.java @@ -27,7 +27,6 @@ import org.apache.iceberg.CatalogProperties; import org.apache.iceberg.hadoop.HadoopCatalog; -import java.util.HashMap; import java.util.Map; public class IcebergHadoopExternalCatalog extends IcebergExternalCatalog { @@ -56,8 +55,8 @@ protected void initCatalog() { HadoopCatalog hadoopCatalog = new HadoopCatalog(); Configuration conf = getConfiguration(); initS3Param(conf); - // initialize hive catalog - Map catalogProperties = new HashMap<>(); + // initialize hadoop catalog + Map catalogProperties = catalogProperty.getProperties(); String warehouse = catalogProperty.getHadoopProperties().get(CatalogProperties.WAREHOUSE_LOCATION); hadoopCatalog.setConf(conf); catalogProperties.put(CatalogProperties.WAREHOUSE_LOCATION, warehouse);