You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ca...@apache.org on 2021/12/23 05:30:54 UTC
[dolphinscheduler] branch 2.0.2-prepare updated: fix 7534 (#7567)
This is an automated email from the ASF dual-hosted git repository.
caishunfeng pushed a commit to branch 2.0.2-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/2.0.2-prepare by this push:
new 5c297a5 fix 7534 (#7567)
5c297a5 is described below
commit 5c297a594c78dbfea966e3ab26aa4657bce33ea4
Author: xiangzihao <46...@qq.com>
AuthorDate: Thu Dec 23 13:30:45 2021 +0800
fix 7534 (#7567)
Co-authored-by: SbloodyS <sb...@qq.com>
---
.../dolphinscheduler/server/master/registry/MasterRegistryClient.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
index 5f1eff6..aaf1d90 100644
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
@@ -537,8 +537,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);