Skip to content

Commit 6d179a6

Browse files
mccheahfoxish
authored andcommitted
Pass the actual iterable from the option to get files (apache#139)
* Pass the actual iterable from the option to get files * Split the original instance variables * Explicitly set the type of the array
1 parent 6f27fb3 commit 6d179a6

File tree

1 file changed

+4
-0
lines changed
  • resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes

1 file changed

+4
-0
lines changed

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,11 @@ private[spark] class Client(
6262
private val uiPort = sparkConf.getInt("spark.ui.port", DEFAULT_UI_PORT)
6363
private val driverSubmitTimeoutSecs = sparkConf.get(KUBERNETES_DRIVER_SUBMIT_TIMEOUT)
6464
private val sparkFiles = sparkConf.getOption("spark.files")
65+
.map(_.split(","))
66+
.getOrElse(Array.empty[String])
6567
private val sparkJars = sparkConf.getOption("spark.jars")
68+
.map(_.split(","))
69+
.getOrElse(Array.empty[String])
6670

6771
private val waitForAppCompletion: Boolean = sparkConf.get(WAIT_FOR_APP_COMPLETION)
6872

0 commit comments

Comments
 (0)