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 5f1eff628f..aaf1d90908 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);