[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/e11ea3f5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e11ea3f5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e11ea3f5 Branch: refs/heads/flip-6 Commit: e11ea3f52fc1e1676bfdbb8171c804cfa184f2b0 Parents: 887cbb9 Author: shuai.xus <[email protected]> Authored: Wed Nov 30 17:02:49 2016 +0800 Committer: Stephan Ewen <[email protected]> Committed: Mon Dec 5 02:49:43 2016 +0100 ---------------------------------------------------------------------- .../runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/e11ea3f5/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
