Skip to content

Commit ec48ccf

Browse files
committed
Fix unit test failure
Change-Id: Ib5e831e46aee395833af5ac4829f7da0a5e6282c
1 parent 9e15391 commit ec48ccf

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff 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

0 commit comments

Comments
 (0)