Add back

risingwavelabs · Jul 18, 2024 · 5cc39ac · 5cc39ac
1 parent 67ed521
commit 5cc39ac
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/connector/src/sink/iceberg/storage_catalog.rs b/src/connector/src/sink/iceberg/storage_catalog.rs
@@ -36,6 +36,7 @@ pub struct StorageCatalogConfig {
     secret_key: String,
     endpoint: Option<String>,
     region: Option<String>,
+    path_style_access: bool,
 }
 
 /// File system catalog.
@@ -61,6 +62,8 @@ 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(),