Repository: samza Updated Branches: refs/heads/0.13.0 9f60e980b -> 94b2f9eec
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/345cef89 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/345cef89 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/345cef89 Branch: refs/heads/0.13.0 Commit: 345cef89d30d73a760c66abce5d8456a71605e68 Parents: 9f60e98 Author: Boris Shkolnik <[email protected]> Authored: Thu May 11 11:35:55 2017 -0700 Committer: Xinyu Liu <[email protected]> Committed: Mon May 15 14:37:06 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/345cef89/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
