Skip to content

Commit 0025474

Browse files
committed
Revert SparkSubmit handling of --driver-* options for only cluster mode
1 parent a2ab1b0 commit 0025474

File tree

1 file changed

+9
-6
lines changed

1 file changed

+9
-6
lines changed

core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -171,12 +171,6 @@ object SparkSubmit {
171171
OptionAssigner(args.master, ALL_CLUSTER_MGRS, ALL_DEPLOY_MODES, sysProp = "spark.master"),
172172
OptionAssigner(args.name, ALL_CLUSTER_MGRS, ALL_DEPLOY_MODES, sysProp = "spark.app.name"),
173173
OptionAssigner(args.jars, ALL_CLUSTER_MGRS, ALL_DEPLOY_MODES, sysProp = "spark.jars"),
174-
OptionAssigner(args.driverExtraClassPath, ALL_CLUSTER_MGRS, ALL_DEPLOY_MODES,
175-
sysProp = "spark.driver.extraClassPath"),
176-
OptionAssigner(args.driverExtraJavaOptions, ALL_CLUSTER_MGRS, ALL_DEPLOY_MODES,
177-
sysProp = "spark.driver.extraJavaOptions"),
178-
OptionAssigner(args.driverExtraLibraryPath, ALL_CLUSTER_MGRS, ALL_DEPLOY_MODES,
179-
sysProp = "spark.driver.extraLibraryPath"),
180174

181175
// Standalone cluster only
182176
OptionAssigner(args.driverMemory, STANDALONE, CLUSTER, clOption = "--memory"),
@@ -207,6 +201,15 @@ object SparkSubmit {
207201
sysProp = "spark.cores.max"),
208202
OptionAssigner(args.files, LOCAL | STANDALONE | MESOS, ALL_DEPLOY_MODES,
209203
sysProp = "spark.files")
204+
205+
// Only process driver specific options for cluster mode here,
206+
// because they have already been processed in bash for client mode
207+
OptionAssigner(args.driverExtraClassPath, STANDALONE | YARN, CLUSTER,
208+
sysProp = "spark.driver.extraClassPath"),
209+
OptionAssigner(args.driverExtraJavaOptions, STANDALONE | YARN, CLUSTER,
210+
sysProp = "spark.driver.extraJavaOptions"),
211+
OptionAssigner(args.driverExtraLibraryPath, STANDALONE | YARN, CLUSTER,
212+
sysProp = "spark.driver.extraLibraryPath"),
210213
)
211214

212215
// In client mode, launch the application main class directly

0 commit comments

Comments
 (0)