[dolphinscheduler] branch dev updated: [Fix-7534][Master] zookeeper failover error (#7562)

[caishunfeng]

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

caishunfeng 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 1efa85c  [Fix-7534][Master] zookeeper failover error (#7562)
1efa85c is described below

commit 1efa85ca27209772ebbb5efbaead036fb33815c0
Author: xiangzihao <460888...@qq.com>
AuthorDate: Fri Dec 24 11:40:21 2021 +0800

    [Fix-7534][Master] zookeeper failover error (#7562)
    
    * fix bug_7534
    
    * fix bug_7534
    
    * fix bug_7534
    
    * fix bug_7534
    
    * fix bug_7534
    
    * fix bug_7534
    
    Co-authored-by: SbloodyS <sbloo...@qq.com>
---
 .../dolphinscheduler/server/master/registry/MasterRegistryClient.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
index 67c8e94..58a0b6a 100644
--- 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
+++ 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
@@ -427,8 +427,7 @@ public class MasterRegistryClient {
                 logger.debug("registry connection state is {}", state);
                 break;
             case SUSPENDED:
-                logger.warn("registry connection state is {}, ready to stop 
myself", state);
-                registryClient.getStoppable().stop("registry connection state 
is SUSPENDED, stop myself");
+                logger.warn("registry connection state is {}, ready to retry 
connection", state);
                 break;
             case RECONNECTED:
                 logger.debug("registry connection state is {}, clean the node 
info", state);