Skip to content
This repository was archived by the owner on Jan 9, 2020. It is now read-only.

Commit 28562e2

Browse files
foxishash211
authored andcommitted
Added service name as prefix to executor pods (#14)
* Added service name as prefix to executor pods to be able to tell them apart from kubectl output * Addressed comments
1 parent 39bf95a commit 28562e2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/kubernetes/KubernetesClusterSchedulerBackend.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ private[spark] class KubernetesClusterSchedulerBackend(
155155
private def allocateNewExecutorPod(): (String, Pod) = {
156156
val executorKubernetesId = UUID.randomUUID().toString.replaceAll("-", "")
157157
val executorId = EXECUTOR_ID_COUNTER.incrementAndGet().toString
158-
val name = s"exec$executorKubernetesId"
158+
val name = s"$kubernetesDriverServiceName-exec-$executorKubernetesId"
159159
val selectors = Map(SPARK_EXECUTOR_SELECTOR -> executorId,
160160
SPARK_APP_SELECTOR -> applicationId()).asJava
161161
val executorMemoryQuantity = new QuantityBuilder(false)

0 commit comments

Comments
 (0)