Repository: samza Updated Branches: refs/heads/master f6d0d6551 -> 46263677d
SAMZA-1286: Close zk connection in ZkController.stop() Author: Boris Shkolnik <[email protected]> Reviewers: Xinyu Liu <[email protected]> Closes #185 from sborya/ZkControllerClose Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/46263677 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/46263677 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/46263677 Branch: refs/heads/master Commit: 46263677d84fd2bcd7575941e6b1e5ec671a8e47 Parents: f6d0d65 Author: Boris Shkolnik <[email protected]> Authored: Thu May 11 11:35:55 2017 -0700 Committer: Xinyu Liu <[email protected]> Committed: Thu May 11 11:35:55 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/samza/zk/ZkControllerImpl.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/46263677/samza-core/src/main/java/org/apache/samza/zk/ZkControllerImpl.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/zk/ZkControllerImpl.java b/samza-core/src/main/java/org/apache/samza/zk/ZkControllerImpl.java index 0b831f8..44d2e37 100644 --- a/samza-core/src/main/java/org/apache/samza/zk/ZkControllerImpl.java +++ b/samza-core/src/main/java/org/apache/samza/zk/ZkControllerImpl.java @@ -76,6 +76,11 @@ public class ZkControllerImpl implements ZkController { if (isLeader()) { zkLeaderElector.resignLeadership(); } + + // close zk connection + if (zkUtils != null) { + zkUtils.getZkClient().close(); + } } @Override
