You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/12/05 01:59:55 UTC
[06/10] flink git commit: [FLINK-5190] [runtime] fix
ZooKeeperLeaderRetrievalService close the zk client when stopping bug
[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 <sh...@alibaba-inc.com>
Authored: Wed Nov 30 17:02:49 2016 +0800
Committer: Stephan Ewen <se...@apache.org>
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