From edb49da19890b8689c726fc2f839b7e2e76bdbd9 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 (cherry picked from commit 913a60e9d8b5bbe043f394c0bab8dc130396d807) --- .../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 aa273a024f6f9..f691302421333 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)