diff --git a/src/connector/src/sink/iceberg/mod.rs b/src/connector/src/sink/iceberg/mod.rs index 51bd9f92de507..e2247a514e875 100644 --- a/src/connector/src/sink/iceberg/mod.rs +++ b/src/connector/src/sink/iceberg/mod.rs @@ -523,7 +523,6 @@ impl IcebergConfig { .secret_key(self.secret_key.clone()) .region(self.region.clone()) .endpoint(self.endpoint.clone()) - .path_style_access(self.path_style_access) .build(); let catalog = storage_catalog::StorageCatalog::new(config)?; Ok(Arc::new(catalog)) diff --git a/src/connector/src/sink/iceberg/storage_catalog.rs b/src/connector/src/sink/iceberg/storage_catalog.rs index b74870408084e..5fb2c5105fda5 100644 --- a/src/connector/src/sink/iceberg/storage_catalog.rs +++ b/src/connector/src/sink/iceberg/storage_catalog.rs @@ -36,7 +36,6 @@ pub struct StorageCatalogConfig { secret_key: String, endpoint: Option, region: Option, - path_style_access: bool, } /// File system catalog. @@ -62,8 +61,6 @@ impl StorageCatalog { } else { file_io_builder }; - file_io_builder = - file_io_builder.with_prop("path_style_access", &config.path_style_access.to_string()); Ok(StorageCatalog { warehouse: config.warehouse.clone(),