(dolphinscheduler) branch dev updated: [Fix-17527][registry-api] Fix Master Worker API startup fails to clean failover finished nodes due to invalid ZooKeeper path (#17663)

[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 46ab5e241c [Fix-17527][registry-api] Fix Master Worker API startup 
fails to clean failover finished nodes due to invalid ZooKeeper path (#17663)
46ab5e241c is described below

commit 46ab5e241c6c41d01d840e16e6acd743a3c4563e
Author: qiong-zhou <zhouqiong...@gmail.com>
AuthorDate: Tue Nov 11 09:56:59 2025 +0800

    [Fix-17527][registry-api] Fix Master Worker API startup fails to clean 
failover finished nodes due to invalid ZooKeeper path (#17663)
---
 .../apache/dolphinscheduler/registry/api/RegistryClient.java   | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/dolphinscheduler-registry/dolphinscheduler-registry-api/src/main/java/org/apache/dolphinscheduler/registry/api/RegistryClient.java
 
b/dolphinscheduler-registry/dolphinscheduler-registry-api/src/main/java/org/apache/dolphinscheduler/registry/api/RegistryClient.java
index 75b817c2d9..86ab82ea31 100644
--- 
a/dolphinscheduler-registry/dolphinscheduler-registry-api/src/main/java/org/apache/dolphinscheduler/registry/api/RegistryClient.java
+++ 
b/dolphinscheduler-registry/dolphinscheduler-registry-api/src/main/java/org/apache/dolphinscheduler/registry/api/RegistryClient.java
@@ -242,16 +242,18 @@ public class RegistryClient {
             return;
         }
         for (final String failoverFinishedNode : failoverFinishedNodes) {
+            final String failoverFinishedNodePath = 
RegistryNodeType.FAILOVER_FINISH_NODES.getRegistryPath()
+                    + Constants.SINGLE_SLASH + failoverFinishedNode;
             try {
-                final String failoverFinishTime = 
registry.get(failoverFinishedNode);
+                final String failoverFinishTime = 
registry.get(failoverFinishedNodePath);
                 if (System.currentTimeMillis() - 
Long.parseLong(failoverFinishTime) > TimeUnit.DAYS.toMillis(7)) {
-                    registry.delete(failoverFinishedNode);
+                    registry.delete(failoverFinishedNodePath);
                     log.info(
                             "Clear the failover finished node: {} which 
failover time is before the current time minus 1 week",
-                            failoverFinishedNode);
+                            failoverFinishedNodePath);
                 }
             } catch (Exception ex) {
-                log.error("Failed to clean the failoverFinishedNode: {}", 
failoverFinishedNode, ex);
+                log.error("Failed to clean the failoverFinishedNode: {}", 
failoverFinishedNodePath, ex);
             }
         }
     }