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 <[email protected]>
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;