flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [45/52] [abbrv] flink git commit: [FLINK-5190] [runtime] fix ZooKeeperLeaderRetrievalService close the zk client when stopping bug
Date Fri, 23 Dec 2016 20:23:04 GMT
[FLINK-5190] [runtime] fix ZooKeeperLeaderRetrievalService close the zk client when stopping
bug


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cbfb807d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cbfb807d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cbfb807d

Branch: refs/heads/master
Commit: cbfb807d65b68b2b6157e1b1d42606123ea499ad
Parents: 95c6829
Author: shuai.xus <shuai.xus@alibaba-inc.com>
Authored: Wed Nov 30 17:02:49 2016 +0800
Committer: Stephan Ewen <sewen@apache.org>
Committed: Fri Dec 23 20:54:27 2016 +0100

----------------------------------------------------------------------
 .../runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java    | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/cbfb807d/flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
index 4587bad..f74fb1a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
@@ -96,7 +96,6 @@ public class ZooKeeperLeaderRetrievalService implements LeaderRetrievalService,
 		client.getConnectionStateListenable().removeListener(connectionStateListener);
 
 		cache.close();
-		client.close();
 	}
 
 	@Override


Mime
View raw message