File tree Expand file tree Collapse file tree 2 files changed +5
-0
lines changed
resource-managers/kubernetes/core/src
main/scala/org/apache/spark/deploy/k8s
test/scala/org/apache/spark/deploy/k8s Expand file tree Collapse file tree 2 files changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -256,6 +256,7 @@ private[spark] object KubernetesConf {
256256 .toLowerCase(Locale .ROOT )
257257 .replaceAll(" [^a-z0-9\\ -]" , " -" )
258258 .replaceAll(" -+" , " -" )
259+ .replaceAll(" ^-" , " " )
259260 }
260261
261262 def getAppNameLabel (appName : String ): String = {
Original file line number Diff line number Diff line change @@ -250,4 +250,8 @@ class KubernetesConfSuite extends SparkFunSuite {
250250 assert(KubernetesConf .getAppNameLabel(" a" * 62 + " -aaa" ) === " a" * 62 )
251251 assert(KubernetesConf .getAppNameLabel(" -" + " a" * 63 ) === " a" * 62 )
252252 }
253+
254+ test(" SPARK-40869: KubernetesConf.getResourceNamePrefix creates invalid name prefixes" ) {
255+ assert(KubernetesConf .getResourceNamePrefix(" _hello_" ).startsWith(" hello" ))
256+ }
253257}
You can’t perform that action at this time.
0 commit comments