Repository: accumulo Updated Branches: refs/heads/1.6 628956706 -> 8f4eae77d refs/heads/master ca4e15b5d -> 83690568b
ACCUMULO-3269 Set REUSEADDR on the Socket. Setting SO_REUSEADDR on the Socket used to ask ZooKeeper if "it's ok" appears to help mitigate the spurious issue when ZooKeeper would fail to bind to an otherwise free port. Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/8f4eae77 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/8f4eae77 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/8f4eae77 Branch: refs/heads/1.6 Commit: 8f4eae77d12e4b3a54ef2cd176c7cd26b2af326a Parents: 6289567 Author: Josh Elser <els...@apache.org> Authored: Mon Dec 8 15:40:43 2014 -0500 Committer: Josh Elser <els...@apache.org> Committed: Mon Dec 8 15:40:43 2014 -0500 ---------------------------------------------------------------------- .../apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/8f4eae77/minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java ---------------------------------------------------------------------- diff --git a/minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java b/minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java index 244b721..8877b5d 100644 --- a/minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java +++ b/minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java @@ -539,6 +539,7 @@ public class MiniAccumuloClusterImpl implements AccumuloCluster { Socket s = null; try { s = new Socket("localhost", config.getZooKeeperPort()); + s.setReuseAddress(true); s.getOutputStream().write("ruok\n".getBytes()); s.getOutputStream().flush(); byte buffer[] = new byte[100];
