fix(iceberg): Table desc should allow nested db_name (#16414)

Signed-off-by: Xuanwo <[email protected]>
databendlabs · Sep 13, 2024 · be0597b · be0597b
1 parent 007a076
commit be0597b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/query/storages/iceberg/src/table.rs b/src/query/storages/iceberg/src/table.rs
@@ -72,7 +72,7 @@ impl IcebergTable {
     #[async_backtrace::framed]
     pub fn try_create(info: TableInfo) -> Result<Box<dyn Table>> {
         let ctl = IcebergCatalog::try_create(info.catalog_info.clone())?;
-        let (db_name, table_name) = info.desc.as_str().split_once(',').ok_or_else(|| {
+        let (db_name, table_name) = info.desc.as_str().rsplit_once('.').ok_or_else(|| {
             ErrorCode::BadArguments(format!("Iceberg table desc {} is invalid", &info.desc))
         })?;
         Ok(Box::new(Self {