[FLINK-7021] Unregister ZooKeeperLeaderRetrievalService from CuratorFramework at shut down
When stopping the ZooKeeperLeaderRetrievalService, then we also have to unregister this from the CuratorFramework#getUnhandledErrorListenable. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/240542f7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/240542f7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/240542f7 Branch: refs/heads/master Commit: 240542f701e06b28a35faaa7e6200183cfdfa455 Parents: 45aceb4 Author: Till <[email protected]> Authored: Wed Oct 18 13:57:22 2017 +0200 Committer: Till <[email protected]> Committed: Thu Oct 19 14:59:00 2017 +0200 ---------------------------------------------------------------------- .../runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/240542f7/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 d5e172b..00ba66c 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 @@ -121,6 +121,7 @@ public class ZooKeeperLeaderRetrievalService implements LeaderRetrievalService, running = false; } + client.getUnhandledErrorListenable().removeListener(this); client.getConnectionStateListenable().removeListener(connectionStateListener); try {
