From 8e25a90f5721c0087e489055be9b9808dd24b99f Mon Sep 17 00:00:00 2001 From: yimaixinchen Date: Thu, 18 Feb 2021 18:02:36 +0800 Subject: [PATCH] =?UTF-8?q?initStateLister=E5=90=8D=E5=AD=97=E6=94=B9?= =?UTF-8?q?=E4=B8=BAinitStateListener=20(#4793)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: v_taoouyang --- .../apache/dolphinscheduler/service/zk/ZookeeperOperator.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 2396da485a..5d4da2ce64 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 @@ -55,7 +55,7 @@ public class ZookeeperOperator implements InitializingBean { @Override public void afterPropertiesSet() throws Exception { this.zkClient = buildClient(); - initStateLister(); + initStateListener(); treeCacheStart(); } @@ -66,7 +66,7 @@ public class ZookeeperOperator implements InitializingBean { protected void treeCacheStart(){} - public void initStateLister() { + public void initStateListener() { checkNotNull(zkClient); zkClient.getConnectionStateListenable().addListener((client, newState) -> {