Merge branch 'master' into fix-expire-data-after-dropping-partition

apache · Dec 11, 2024 · e76fcff · e76fcff
2 parents 758ccf3 + 24cec41
commit e76fcff
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/amoro-ams/src/main/java/org/apache/amoro/server/terminal/SparkContextUtil.java b/amoro-ams/src/main/java/org/apache/amoro/server/terminal/SparkContextUtil.java
@@ -57,7 +57,9 @@ public static Map<String, String> getSparkConf(Configurations sessionConfig) {
           sessionConfig.get(TerminalSessionFactory.SessionConfigOptions.catalogConnector(catalog));
       String catalogClassName;
       String sparkCatalogPrefix = "spark.sql.catalog." + catalog;
-      if ("arctic".equalsIgnoreCase(connector)) {
+      if ("arctic".equalsIgnoreCase(connector)
+          || "mixed_iceberg".equalsIgnoreCase(connector)
+          || "mixed_hive".equalsIgnoreCase(connector)) {
         catalogClassName = MIXED_FORMAT_CATALOG;
         String type =
             sessionConfig.get(