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 753971be9 [HotFix] Change the uri configuration name in terminal
(#3844)
753971be9 is described below
commit 753971be99683694918aaac171391017ffbb3c7c
Author: ZhouJinsong <[email protected]>
AuthorDate: Fri Oct 31 14:08:55 2025 +0800
[HotFix] Change the uri configuration name in terminal (#3844)
Change the uri configuration in terminal
---
.../main/java/org/apache/amoro/server/terminal/SparkContextUtil.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 4139414ee..1bd0edceb 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
@@ -74,7 +74,7 @@ public class SparkContextUtil {
sparkCatalogPrefix = "spark.sql.catalog.spark_catalog";
catalogClassName = MIXED_FORMAT_SESSION_CATALOG;
}
- sparkConf.put(sparkCatalogPrefix + ".url", catalogUrlBase + "/" +
catalog);
+ sparkConf.put(sparkCatalogPrefix + ".ams.uri", catalogUrlBase + "/" +
catalog);
} else if ("unified".equalsIgnoreCase(connector)) {
catalogClassName = UNIFIED_CATALOG;
String type =
@@ -86,7 +86,7 @@ public class SparkContextUtil {
sparkCatalogPrefix = "spark.sql.catalog.spark_catalog";
catalogClassName = UNIFIED_SESSION_CATALOG;
}
- sparkConf.put(sparkCatalogPrefix + ".uri", catalogUrlBase + "/" +
catalog);
+ sparkConf.put(sparkCatalogPrefix + ".ams.uri", catalogUrlBase + "/" +
catalog);
} else {
catalogClassName = "iceberg".equalsIgnoreCase(connector) ?
ICEBERG_CATALOG : PAIMON_CATALOG;
Map<String, String> properties =