[hotfix] Fixed incorrect use of the paimon catalog (#3362)

fix catalog
apache · Dec 10, 2024 · 24cec41 · 24cec41
1 parent 2298331
commit 24cec41
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(