diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/zk/ZookeeperOperator.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/zk/ZookeeperOperator.java index 8a219837b7..8ea9ea5ba3 100644 --- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/zk/ZookeeperOperator.java +++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/zk/ZookeeperOperator.java @@ -59,7 +59,7 @@ public class ZookeeperOperator implements InitializingBean { @Override public void afterPropertiesSet() throws Exception { this.zkClient = buildClient(); - initStateLister(); + initStateListener(); treeCacheStart(); } @@ -74,7 +74,7 @@ public class ZookeeperOperator implements InitializingBean { // Used by sub class } - public void initStateLister() { + public void initStateListener() { checkNotNull(zkClient); zkClient.getConnectionStateListenable().addListener((client, newState) -> {