Browse Source

fix zk path error (#3470)

zixi0825 4 years ago
parent
commit
a7a1156ff1

+ 1 - 1
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerRegistry.java

@@ -152,7 +152,7 @@ public class WorkerRegistry {
             // trim and lower case is need
             workerZkPathBuilder.append(workGroup.trim().toLowerCase()).append(SLASH);
             workerZkPathBuilder.append(address);
-            workerZkPathBuilder.append(weight).append(SLASH);
+            workerZkPathBuilder.append(weight);
             workerZkPaths.add(workerZkPathBuilder.toString());
         }
         return workerZkPaths;