From 7ef95e351704685ca599709c6386b9a72d6a1d7a Mon Sep 17 00:00:00 2001 From: Dylan Chen Date: Tue, 10 Dec 2024 14:34:01 +0800 Subject: [PATCH] fix iceberg config load --- src/connector/src/connector_common/iceberg/mod.rs | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/connector/src/connector_common/iceberg/mod.rs b/src/connector/src/connector_common/iceberg/mod.rs index a24dc3500cd98..bc1b9d07e6663 100644 --- a/src/connector/src/connector_common/iceberg/mod.rs +++ b/src/connector/src/connector_common/iceberg/mod.rs @@ -208,7 +208,7 @@ impl IcebergCommon { let enable_config_load = self.enable_config_load.unwrap_or(false); iceberg_configs.insert( "iceberg.table.io.disable_config_load".to_string(), - enable_config_load.to_string(), + (!enable_config_load).to_string(), ); load_iceberg_base_catalog_config(&iceberg_configs)? @@ -434,11 +434,10 @@ mod v1 { } } - // #TODO - // Support load config file + let enable_config_load = self.enable_config_load.unwrap_or(false); iceberg_configs.insert( "iceberg.table.io.disable_config_load".to_string(), - "true".to_string(), + (!enable_config_load).to_string(), ); Ok(iceberg_configs)