change iceberg glue catalog default implemantation to java

risingwavelabs · Jan 8, 2025 · 0c70f0a · 0c70f0a
1 parent 1ac4375
commit 0c70f0a
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/connector/src/connector_common/iceberg/mod.rs b/src/connector/src/connector_common/iceberg/mod.rs
@@ -387,7 +387,7 @@ impl IcebergCommon {
                 let catalog = iceberg_catalog_rest::RestCatalog::new(config);
                 Ok(Arc::new(catalog))
             }
-            "glue" => {
+            "glue_rest" => {
                 let mut iceberg_configs = HashMap::new();
                 // glue
                 if let Some(region) = &self.region {
@@ -427,7 +427,10 @@ impl IcebergCommon {
                 Ok(Arc::new(catalog))
             }
             catalog_type
-                if catalog_type == "hive" || catalog_type == "jdbc" || catalog_type == "rest" =>
+                if catalog_type == "hive"
+                    || catalog_type == "jdbc"
+                    || catalog_type == "rest"
+                    || catalog_type == "glue" =>
             {
                 // Create java catalog
                 let (file_io_props, java_catalog_props) =
@@ -436,6 +439,7 @@ impl IcebergCommon {
                     "hive" => "org.apache.iceberg.hive.HiveCatalog",
                     "jdbc" => "org.apache.iceberg.jdbc.JdbcCatalog",
                     "rest" => "org.apache.iceberg.rest.RESTCatalog",
+                    "glue" => "org.apache.iceberg.aws.glue.GlueCatalog",
                     _ => unreachable!(),
                 };