ACCUMULO-1889 mark ZKI as closed once close() is called. Once a given ZKI has .close() called, mark that instance closed regardless of outstanding client count.
Signed-off-by: Eric Newton <eric.new...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/ada41803 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/ada41803 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/ada41803 Branch: refs/heads/1.6.0-SNAPSHOT Commit: ada4180379d46297c1531cf8065de5030d12953d Parents: d8b4ba9 Author: Sean Busbey <bus...@clouderagovt.com> Authored: Wed Nov 13 10:58:15 2013 -0600 Committer: Eric Newton <eric.new...@gmail.com> Committed: Tue Nov 19 12:30:24 2013 -0500 ---------------------------------------------------------------------- .../java/org/apache/accumulo/core/client/ZooKeeperInstance.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/ada41803/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java ---------------------------------------------------------------------- diff --git a/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java b/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java index 1dae711..069d217 100644 --- a/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java +++ b/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java @@ -306,8 +306,8 @@ public class ZooKeeperInstance implements Instance { clientInstances.incrementAndGet(); throw new AccumuloException("Issues closing ZooKeeper."); } - closed = true; } + closed = true; } @Override
