From 6bf21727a65f72fcc7cddec39a76faeeab75ec80 Mon Sep 17 00:00:00 2001 From: hehuiyuan Date: Sat, 23 Mar 2019 22:30:49 +0800 Subject: [PATCH] Add the prefix 'spark-' for resourceNamePrefix that starts with number --- .../scala/org/apache/spark/deploy/k8s/KubernetesConf.scala | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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 index 5e741112fc7e..93d40e91d3d8 100644 --- 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 @@ -78,7 +78,10 @@ private[spark] class KubernetesDriverConf( override val resourceNamePrefix: String = { val custom = if (Utils.isTesting) get(KUBERNETES_DRIVER_POD_NAME_PREFIX) else None - custom.getOrElse(KubernetesConf.getResourceNamePrefix(appName)) + val resourceNamePrefix = custom.getOrElse(KubernetesConf.getResourceNamePrefix(appName)) + // If the first character of resourceNamePrefix is number,add the extra prefix : "spark-". + val prefix = "spark-" + resourceNamePrefix.charAt(0) + resourceNamePrefix.replaceAll("^[0-9]", prefix) } override def labels: Map[String, String] = {