Skip to content

Commit 3741f96

Browse files
committed
Fix the bug when user has set the spark.app.id value
1 parent c1d8af1 commit 3741f96

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spark-submission-worker/src/main/java/org/apache/spark/k8s/operator/SparkAppSubmissionWorker.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ protected SparkAppDriverConf buildDriverConf(
126126
effectiveSparkConf.setIfMissing("spark.app.id", appId);
127127
return SparkAppDriverConf.create(
128128
effectiveSparkConf,
129-
appId,
129+
effectiveSparkConf.getAppId(),
130130
primaryResource,
131131
applicationSpec.getMainClass(),
132132
applicationSpec.getDriverArgs().toArray(String[]::new),

0 commit comments

Comments
 (0)