This is an automated email from the ASF dual-hosted git repository.
zihaoxiang 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 1c836bf011 [Fix-13950][master] fix the key of master node failover
(#13952)
1c836bf011 is described below
commit 1c836bf011af0ad24e4d80d32c1ef84b21ee0e30
Author: eye-gu <[email protected]>
AuthorDate: Wed Apr 19 17:52:38 2023 +0800
[Fix-13950][master] fix the key of master node failover (#13952)
Co-authored-by: eye <[email protected]>
---
.../dolphinscheduler/server/master/service/MasterFailoverService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/MasterFailoverService.java
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/MasterFailoverService.java
index 45504a9a86..7368dc8d9f 100644
---
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/MasterFailoverService.java
+++
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/MasterFailoverService.java
@@ -91,7 +91,7 @@ public class MasterFailoverService {
}
public void failoverMaster(String masterHost) {
- String failoverPath = RegistryNodeType.MASTER_FAILOVER_LOCK + "/" +
masterHost;
+ String failoverPath =
RegistryNodeType.MASTER_FAILOVER_LOCK.getRegistryPath() + "/" + masterHost;
try {
registryClient.getLock(failoverPath);
doFailoverMaster(masterHost);