File tree Expand file tree Collapse file tree 1 file changed +5
-0
lines changed
core/src/main/scala/org/apache/spark/deploy Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -485,12 +485,17 @@ object SparkSubmit extends CommandLineUtils {
485485
486486 // In client mode, launch the application main class directly
487487 // In addition, add the main application jar and any added jars (if any) to the classpath
488+ // Also add the main application jar and any added jars to classpath in case yarn#client
489+ // requires these jars.
488490 if (deployMode == CLIENT || isYarnCluster) {
489491 childMainClass = args.mainClass
490492 if (isUserJar(args.primaryResource)) {
491493 childClasspath += args.primaryResource
492494 }
493495 if (args.jars != null ) { childClasspath ++= args.jars.split(" ," ) }
496+ }
497+
498+ if (deployMode == CLIENT ) {
494499 if (args.childArgs != null ) { childArgs ++= args.childArgs }
495500 }
496501
You can’t perform that action at this time.
0 commit comments