fix(nimtable): fix database path (#19182)

risingwavelabs · Nov 4, 2024 · 30fbc6b · 30fbc6b
1 parent e6568e7
commit 30fbc6b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/connector/src/connector_common/iceberg/mod.rs b/src/connector/src/connector_common/iceberg/mod.rs
@@ -131,7 +131,7 @@ impl IcebergCommon {
                     "To create an iceberg engine table, NIMTABLE_DATA_DIRECTORY needed to be set"
                 );
             };
-            let warehouse_path = format!("s3://{}/{}/nimtable", s3_bucket, data_directory);
+            let warehouse_path = format!("s3://{}/{}/nimtable/{}", s3_bucket, data_directory, self.database_name.clone().unwrap());
 
             let (bucket, _) = {
                 let url = Url::parse(&warehouse_path)

diff --git a/src/frontend/src/handler/create_table.rs b/src/frontend/src/handler/create_table.rs
@@ -1514,7 +1514,7 @@ pub async fn handle_create_table(
                 }
             };
 
-            let warehouse_path = format!("s3://{}/{}/nimtable", s3_bucket, data_directory);
+            let warehouse_path = format!("s3://{}/{}/nimtable/{}", s3_bucket, data_directory, iceberg_catalog_name);
 
             let mut sink_handler_args = handler_args.clone();
             let mut with = BTreeMap::new();