You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@amoro.apache.org by ji...@apache.org on 2024/12/10 07:52:11 UTC
(amoro) branch master updated: [hotfix] Fixed incorrect use of the paimon catalog (#3362)
This is an automated email from the ASF dual-hosted git repository.
jinsongzhou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git
The following commit(s) were added to refs/heads/master by this push:
new 24cec419f [hotfix] Fixed incorrect use of the paimon catalog (#3362)
24cec419f is described below
commit 24cec419f1798338f8ad69da80f8c1005bb15dae
Author: Marig_Weizhi <ma...@foxmail.com>
AuthorDate: Tue Dec 10 15:52:07 2024 +0800
[hotfix] Fixed incorrect use of the paimon catalog (#3362)
fix catalog
---
.../main/java/org/apache/amoro/server/terminal/SparkContextUtil.java | 4 +++-
1 file changed, 3 insertions(+), 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
index 23d76d35c..b373c4625 100644
--- 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 class SparkContextUtil {
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(