Merge pull request apache#9 from ringtail/bugfix/executor-node-name

add default node name
ringtail · Apr 21, 2020 · 2814e60 · 2814e60
2 parents e6b81d8 + ae1ca6b
commit 2814e60
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...tes/core/src/main/scala/org/apache/spark/deploy/k8s/features/BasicDriverFeatureStep.scala b/...tes/core/src/main/scala/org/apache/spark/deploy/k8s/features/BasicDriverFeatureStep.scala
@@ -46,7 +46,7 @@ private[spark] class BasicDriverFeatureStep(
   private val driverLimitCores = conf.get(KUBERNETES_DRIVER_LIMIT_CORES)
 
   // node name of driver
-  private val driverNodeName = conf.get(KUBERNETES_DRIVER_NODE_NAME)
+  private val driverNodeName = conf.get(KUBERNETES_DRIVER_NODE_NAME).getOrElse("")
 
   // Memory settings
   private val driverMemoryMiB = conf.get(DRIVER_MEMORY)

diff --git a/...s/core/src/main/scala/org/apache/spark/deploy/k8s/features/BasicExecutorFeatureStep.scala b/...s/core/src/main/scala/org/apache/spark/deploy/k8s/features/BasicExecutorFeatureStep.scala
@@ -88,7 +88,7 @@ private[spark] class BasicExecutorFeatureStep(
   private val executorLimitCores =
     kubernetesConf.get(KUBERNETES_EXECUTOR_LIMIT_CORES)
 
-  private val executorNodeName = kubernetesConf.get(KUBERNETES_EXECUTOR_NODE_NAME)
+  private val executorNodeName = kubernetesConf.get(KUBERNETES_EXECUTOR_NODE_NAME).getOrElse("")
 
   override def configurePod(pod: SparkPod): SparkPod = {
     val name =