From 8e53f2fdcbd8dbb7ed745f814ea1bbf5627c9251 Mon Sep 17 00:00:00 2001
From: Cancai Cai <77189278+caicancai@users.noreply.github.com>
Date: Thu, 13 Jun 2024 14:04:45 +0800
Subject: [PATCH] [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);