(dolphinscheduler) branch dev updated: [Improvement][Worker] Rename workerZKPath to workerRegistryPath (#16144)

[wenjun]

This is an automated email from the ASF dual-hosted git repository.

wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 8e53f2fdcb [Improvement][Worker] Rename workerZKPath to 
workerRegistryPath (#16144)
8e53f2fdcb is described below

commit 8e53f2fdcbd8dbb7ed745f814ea1bbf5627c9251
Author: Cancai Cai <77189278+caican...@users.noreply.github.com>
AuthorDate: Thu Jun 13 14:04:45 2024 +0800

    [Improvement][Worker] Rename workerZKPath to workerRegistryPath (#16144)
---
 .../server/worker/registry/WorkerRegistryClient.java             | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerRegistryClient.java
 
b/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerRegistryClient.java
index eb7b8d32d2..e963fc0c13 100644
--- 
a/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerRegistryClient.java
+++ 
b/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerRegistryClient.java
@@ -97,11 +97,12 @@ public class WorkerRegistryClient implements AutoCloseable {
             workerHeartBeat = workerHeartBeatTask.getHeartBeat();
             Thread.sleep(SLEEP_TIME_MILLIS);
         }
-        String workerZKPath = workerConfig.getWorkerRegistryPath();
+        String workerRegistryPath = workerConfig.getWorkerRegistryPath();
         // remove before persist
-        registryClient.remove(workerZKPath);
-        registryClient.persistEphemeral(workerZKPath, 
JSONUtils.toJsonString(workerHeartBeat));
-        log.info("Worker node: {} registry to ZK {} successfully", 
workerConfig.getWorkerAddress(), workerZKPath);
+        registryClient.remove(workerRegistryPath);
+        registryClient.persistEphemeral(workerRegistryPath, 
JSONUtils.toJsonString(workerHeartBeat));
+        log.info("Worker node: {} registry to registry center {} 
successfully", workerConfig.getWorkerAddress(),
+                workerRegistryPath);
 
         while 
(!registryClient.checkNodeExists(workerConfig.getWorkerAddress(), 
RegistryNodeType.WORKER)) {
             ThreadUtils.sleep(SLEEP_TIME_MILLIS);