You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2014/09/17 20:03:58 UTC
git commit: ACCUMULO-2964 Try to avoid the exception before tserver
actually starts.
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 <el...@apache.org>
Authored: Wed Sep 17 13:44:38 2014 -0400
Committer: Josh Elser <el...@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);