This is an automated email from the ASF dual-hosted git repository. gabrywu pushed a commit to branch dev in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push: new a7a1156 fix zk path error (#3470) a7a1156 is described below commit a7a1156ff1002031c87c29bd737d8f9f0488cea1 Author: zixi0825 <649790...@qq.com> AuthorDate: Wed Aug 12 17:16:43 2020 +0800 fix zk path error (#3470) --- .../apache/dolphinscheduler/server/worker/registry/WorkerRegistry.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerRegistry.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerRegistry.java index 6204edc..36998fa 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerRegistry.java +++ b/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;