[Hotfix] Spark k8s optimizer release error (#3402)

fix: spark optimizer release error
apache · Jan 15, 2025 · 0678ba0 · 0678ba0
1 parent c72f121
commit 0678ba0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/amoro-ams/src/main/java/org/apache/amoro/server/manager/SparkOptimizerContainer.java b/amoro-ams/src/main/java/org/apache/amoro/server/manager/SparkOptimizerContainer.java
@@ -117,6 +117,7 @@ protected Map<String, String> doScaleOut(Resource resource) {
       if (deployedOnKubernetes()) {
         SparkOptimizerContainer.SparkConf sparkConf =
             SparkOptimizerContainer.SparkConf.buildFor(loadSparkConfig(), getContainerProperties())
+                .withGroupProperties(resource.getProperties())
                 .build();
         String namespace =
             StringUtils.defaultIfEmpty(