From 21423d6f2cb71dc9bddfc8dd2d2e4b9ec34f2e9f Mon Sep 17 00:00:00 2001 From: mccheah Date: Thu, 23 Feb 2017 12:12:35 -0800 Subject: [PATCH] Pass the actual iterable from the option to get files (#139) * Pass the actual iterable from the option to get files * Split the original instance variables * Explicitly set the type of the array --- .../scala/org/apache/spark/deploy/kubernetes/Client.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala index f83dd2824e412..a8b8de8e34d03 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala @@ -62,7 +62,11 @@ private[spark] class Client( private val uiPort = sparkConf.getInt("spark.ui.port", DEFAULT_UI_PORT) private val driverSubmitTimeoutSecs = sparkConf.get(KUBERNETES_DRIVER_SUBMIT_TIMEOUT) private val sparkFiles = sparkConf.getOption("spark.files") + .map(_.split(",")) + .getOrElse(Array.empty[String]) private val sparkJars = sparkConf.getOption("spark.jars") + .map(_.split(",")) + .getOrElse(Array.empty[String]) private val waitForAppCompletion: Boolean = sparkConf.get(WAIT_FOR_APP_COMPLETION)