[NDAP-1966][Fix] ZK path 형식 에러. (#9)

Co-authored-by: paul <[email protected]>
nexr · Mar 15, 2024 · 3b72f8f · 3b72f8f
1 parent 15b3aad
commit 3b72f8f
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/AdminResource.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/AdminResource.scala
@@ -376,8 +376,9 @@ private[v1] class AdminResource extends ApiRequestContext with Logging {
             s"share level: $shareLevel, subdomain: $subdomain")
         case None =>
           discoveryClient.getChildren(engineSpace).map { child =>
-            info(s"Listing engine nodes under $engineSpace/$child")
-            engineNodes ++= discoveryClient.getServiceNodesInfo(s"$engineSpace/$child").map(node =>
+            val path = DiscoveryPaths.makePath(engineSpace, child, null)
+            info(s"Listing engine nodes under $path")
+            engineNodes ++= discoveryClient.getServiceNodesInfo(path).map(node =>
               makeEngineInfo(
                 child,
                 engine.getVersion,
@@ -450,7 +451,11 @@ private[v1] class AdminResource extends ApiRequestContext with Logging {
   }
 
   private def generateEngineSpace(engine: Engine): String = {
-    s"${engine.getNamespace}_${engine.getVersion}_${engine.getSharelevel}_${engine.getEngineType}"
+    val engineSpace = {
+      s"${engine.getNamespace}_${engine.getVersion}_${engine.getSharelevel}_${engine.getEngineType}"
+    }
+
+    DiscoveryPaths.makePath(engineSpace, null, null)
   }
 
   private def calculateEngineSpace(engine: Engine): String = {