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/06/14 06:55:44 UTC
[44/51] [abbrv] git commit: ACCUMULO-378 Test stabilization
ACCUMULO-378 Test stabilization
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/8f531413
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/8f531413
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/8f531413
Branch: refs/heads/master
Commit: 8f53141334822045495e37a62b9a7f4685bbd4dc
Parents: 5365b55
Author: Josh Elser <el...@apache.org>
Authored: Fri Jun 6 13:42:14 2014 -0400
Committer: Josh Elser <el...@apache.org>
Committed: Fri Jun 6 13:42:14 2014 -0400
----------------------------------------------------------------------
.../org/apache/accumulo/test/replication/ReplicationTest.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/8f531413/test/src/test/java/org/apache/accumulo/test/replication/ReplicationTest.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationTest.java b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationTest.java
index 422130c..a9b8b74 100644
--- a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationTest.java
+++ b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationTest.java
@@ -891,6 +891,11 @@ public class ReplicationTest extends ConfigurableMacIT {
conn.tableOperations().compact(ReplicationTable.NAME, null, null, true, true);
+ // Master is creating entries in the replication table from the metadata table every second.
+ // Compaction should trigger the record to be written to metadata. Wait a bit to ensure
+ // that the master has time to work.
+ Thread.sleep(5000);
+
s = ReplicationTable.getScanner(conn);
StatusSection.limit(s);
Assert.assertEquals(2, Iterables.size(s));