You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by li...@apache.org on 2021/02/18 10:02:48 UTC
[incubator-dolphinscheduler] branch 1.3.6-prepare updated: initStateLister名字改为initStateListener (#4793)
This is an automated email from the ASF dual-hosted git repository.
lidongdai pushed a commit to branch 1.3.6-prepare
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git
The following commit(s) were added to refs/heads/1.3.6-prepare by this push:
new 8e25a90 initStateLister名字改为initStateListener (#4793)
8e25a90 is described below
commit 8e25a90f5721c0087e489055be9b9808dd24b99f
Author: yimaixinchen <yi...@163.com>
AuthorDate: Thu Feb 18 18:02:36 2021 +0800
initStateLister名字改为initStateListener (#4793)
Co-authored-by: v_taoouyang <v_...@tencent.com>
---
.../org/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 2396da4..5d4da2c 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) -> {