Skip to content
This repository was archived by the owner on Jan 9, 2020. It is now read-only.

Commit 8751a9a

Browse files
sandfleemccheah
authored andcommitted
fix submit job errors (#376)
1 parent db5f5be commit 8751a9a

File tree

1 file changed

+3
-2
lines changed
  • resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/submit

1 file changed

+3
-2
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/submit/Client.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ private[spark] object ClientArguments {
4242
var otherPyFiles = Seq.empty[String]
4343
var mainClass: Option[String] = None
4444
val driverArgs = mutable.Buffer.empty[String]
45-
args.sliding(2).toList.collect {
45+
args.sliding(2, 2).toList.collect {
4646
case Array("--primary-py-file", mainPyFile: String) =>
4747
mainAppResource = Some(PythonMainAppResource(mainPyFile))
4848
case Array("--primary-java-resource", primaryJavaResource: String) =>
@@ -54,7 +54,8 @@ private[spark] object ClientArguments {
5454
case Array("--arg", arg: String) =>
5555
driverArgs += arg
5656
case other =>
57-
throw new RuntimeException(s"Unknown arguments: $other")
57+
val invalid = other.mkString(" ")
58+
throw new RuntimeException(s"Unknown arguments: $invalid")
5859
}
5960
require(mainAppResource.isDefined,
6061
"Main app resource must be defined by either --primary-py-file or --primary-java-resource.")

0 commit comments

Comments
 (0)