Add workerDecomissioning to K8s conf

holdenk · holdenk · commit c40fac5de1e9 · 2018-08-27T12:13:22.000-07:00
diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/KubernetesConf.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/KubernetesConf.scala
@@ -91,6 +91,9 @@ private[spark] case class KubernetesConf[T <: KubernetesRoleSpecificConf](
       }
   }
 
+  def workerDecomissioning(): Boolean =
+    sparkConf.get(org.apache.spark.internal.config.WORKER_DECOMMISSION_ENABLED)
+
   def nodeSelector(): Map[String, String] =
     KubernetesUtils.parsePrefixedKeyValuePairs(sparkConf, KUBERNETES_NODE_SELECTOR_PREFIX)
 

Original file line number	Diff line number	Diff line change
`@@ -91,6 +91,9 @@ private[spark] case class KubernetesConf[T <: KubernetesRoleSpecificConf](`
`91`	`91`	`}`
`92`	`92`	`}`
`93`	`93`
	`94`	`+ def workerDecomissioning(): Boolean =`
	`95`	`+ sparkConf.get(org.apache.spark.internal.config.WORKER_DECOMMISSION_ENABLED)`
	`96`	`+`
`94`	`97`	`def nodeSelector(): Map[String, String] =`
`95`	`98`	`KubernetesUtils.parsePrefixedKeyValuePairs(sparkConf, KUBERNETES_NODE_SELECTOR_PREFIX)`
`96`	`99`