Skip to content

Commit

Permalink
Added service name as prefix to executor pods (apache#14)
Browse files Browse the repository at this point in the history
* Added service name as prefix to executor pods to be able to tell them apart from kubectl output

* Addressed comments
  • Loading branch information
foxish committed Jul 24, 2017
1 parent 77b287e commit 0bcc391
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -155,7 +155,7 @@ private[spark] class KubernetesClusterSchedulerBackend(
private def allocateNewExecutorPod(): (String, Pod) = {
val executorKubernetesId = UUID.randomUUID().toString.replaceAll("-", "")
val executorId = EXECUTOR_ID_COUNTER.incrementAndGet().toString
val name = s"exec$executorKubernetesId"
val name = s"$kubernetesDriverServiceName-exec-$executorKubernetesId"
val selectors = Map(SPARK_EXECUTOR_SELECTOR -> executorId,
SPARK_APP_SELECTOR -> applicationId()).asJava
val executorMemoryQuantity = new QuantityBuilder(false)
Expand Down

0 comments on commit 0bcc391

Please sign in to comment.