@@ -130,15 +130,22 @@ object KubernetesUtils extends Logging {
130130 .replaceAll(" ^[0-9]" , " x" )
131131 }
132132
133- def generateDriverPodName (
133+ def generateDriverPodName (
134134 appName : String ,
135135 engineRefId : String ,
136136 forciblyRewrite : Boolean ): String = {
137- lazy val resolvedResourceName = s " kyuubi- ${getResourceNamePrefix(appName, engineRefId)}-driver "
137+ val resourceNamePrefix = if (appName.contains(engineRefId)) {
138+ getResourceNamePrefix(appName, " " )
139+ } else {
140+ getResourceNamePrefix(appName, engineRefId)
141+ }
142+ val resolvedResourceName = if (resourceNamePrefix.startsWith(" kyuubi-" )) {
143+ s " $resourceNamePrefix-driver "
144+ } else {
145+ s " kyuubi- $resourceNamePrefix-driver "
146+ }
138147 if (forciblyRewrite || resolvedResourceName.length > DRIVER_POD_NAME_MAX_LENGTH ) {
139148 s " kyuubi- $engineRefId-driver "
140- } else if (appName.contains(engineRefId)){
141- getResourceNamePrefix(appName, " driver" )
142149 } else {
143150 resolvedResourceName
144151 }
@@ -148,11 +155,18 @@ object KubernetesUtils extends Logging {
148155 appName : String ,
149156 engineRefId : String ,
150157 forciblyRewrite : Boolean ): String = {
151- val resolvedResourceName = s " kyuubi- ${getResourceNamePrefix(appName, engineRefId)}"
152- if (forciblyRewrite || resolvedResourceName.length > EXECUTOR_POD_NAME_PREFIX_MAX_LENGTH ) {
158+ val resourceNamePrefix = if (appName.contains(engineRefId)) {
159+ getResourceNamePrefix(appName, " " )
160+ } else {
161+ getResourceNamePrefix(appName, engineRefId)
162+ }
163+ val resolvedResourceName = if (resourceNamePrefix.startsWith(" kyuubi-" )) {
164+ s " $resourceNamePrefix"
165+ } else {
166+ s " kyuubi- $resourceNamePrefix"
167+ }
168+ if (forciblyRewrite || resolvedResourceName.length > DRIVER_POD_NAME_MAX_LENGTH ) {
153169 s " kyuubi- $engineRefId"
154- } else if (appName.contains(engineRefId)){
155- getResourceNamePrefix(appName, " " ).init
156170 } else {
157171 resolvedResourceName
158172 }
0 commit comments