[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 <[email protected]> Authored: Wed Nov 30 17:02:49 2016 +0800 Committer: Stephan Ewen <[email protected]> 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
