Repository: accumulo Updated Branches: refs/heads/master f621977cb -> ff01c6860
ACCUMULO-2964 Try to avoid the exception before tserver actually starts. Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/ff01c686 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/ff01c686 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/ff01c686 Branch: refs/heads/master Commit: ff01c68606b32a49b757fee3f5ace18b1ca30809 Parents: f621977 Author: Josh Elser <els...@apache.org> Authored: Wed Sep 17 13:44:38 2014 -0400 Committer: Josh Elser <els...@apache.org> Committed: Wed Sep 17 13:58:38 2014 -0400 ---------------------------------------------------------------------- .../apache/accumulo/test/replication/CyclicReplicationIT.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/ff01c686/test/src/test/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java b/test/src/test/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java index f5e6df3..bc2ccdf 100644 --- a/test/src/test/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java +++ b/test/src/test/java/org/apache/accumulo/test/replication/CyclicReplicationIT.java @@ -248,6 +248,9 @@ public class CyclicReplicationIT { log.info("Restarted tserver on master1"); + // Try to avoid ACCUMULO-2964 + Thread.sleep(1000); + // Sanity check that the element is there on master1 Scanner s = connMaster1.createScanner(master1Table, Authorizations.EMPTY); Entry<Key,Value> entry = Iterables.getOnlyElement(s); @@ -273,6 +276,9 @@ public class CyclicReplicationIT { master2Cluster.exec(TabletServer.class); + // Try to avoid ACCUMULO-2964 + Thread.sleep(1000); + // Check that the element made it to master2 only once s = connMaster2.createScanner(master2Table, Authorizations.EMPTY); entry = Iterables.getOnlyElement(s);
