Skip to content

Commit b6c57c7

Browse files
foxishash211
authored andcommitted
Make pod name unique using the submission timestamp (apache#32)
1 parent 36c4e94 commit b6c57c7

File tree

1 file changed

+3
-3
lines changed
  • resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes

1 file changed

+3
-3
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -56,10 +56,10 @@ private[spark] class Client(
5656
private val master = rawMaster.replaceFirst("k8s://", "")
5757

5858
private val launchTime = System.currentTimeMillis
59-
private val kubernetesAppId = sparkConf.getOption("spark.app.name")
59+
private val appName = sparkConf.getOption("spark.app.name")
6060
.orElse(sparkConf.getOption("spark.app.id"))
61-
.getOrElse(s"spark-$launchTime")
62-
61+
.getOrElse("spark")
62+
private val kubernetesAppId = s"$appName-$launchTime"
6363
private val secretName = s"spark-submission-server-secret-$kubernetesAppId"
6464
private val driverLauncherSelectorValue = s"driver-launcher-$launchTime"
6565
private val driverDockerImage = sparkConf.get(

0 commit comments

Comments
 (0)