From 6cdd8d6b38651fbf003270d06816bd5061e69d53 Mon Sep 17 00:00:00 2001 From: Andrew Ash Date: Wed, 25 Jan 2017 00:54:42 -0800 Subject: [PATCH] Sanitize kubernetesAppId for use in secret, service, and pod names --- .../main/scala/org/apache/spark/deploy/kubernetes/Client.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala index fe3256b9e12be..a2d68c094fc14 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala @@ -54,7 +54,7 @@ private[spark] class Client( private val appName = sparkConf.getOption("spark.app.name") .orElse(sparkConf.getOption("spark.app.id")) .getOrElse("spark") - private val kubernetesAppId = s"$appName-$launchTime" + private val kubernetesAppId = s"$appName-$launchTime".toLowerCase.replaceAll("\\.", "-") private val secretName = s"spark-submission-server-secret-$kubernetesAppId" private val driverLauncherSelectorValue = s"driver-launcher-$launchTime" private val driverDockerImage = sparkConf.get(