ACCUMULO-3320 Stabilize the test after a noticed failure.
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/20102d55 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/20102d55 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/20102d55 Branch: refs/heads/master Commit: 20102d558db1f212b8c012480cd27d2f95633c93 Parents: 00105ce Author: Josh Elser <els...@apache.org> Authored: Mon Nov 10 11:38:21 2014 -0800 Committer: Josh Elser <els...@apache.org> Committed: Mon Nov 10 13:34:51 2014 -0800 ---------------------------------------------------------------------- .../org/apache/accumulo/test/replication/ReplicationIT.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/20102d55/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java index c514cf8..8a385d1 100644 --- a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java +++ b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationIT.java @@ -775,7 +775,6 @@ public class ReplicationIT extends ConfigurableMacIT { log.warn("Found wals {}", wals); - // for (int j = 0; j < 5; j++) { bw = conn.createBatchWriter(table, new BatchWriterConfig()); m = new Mutation("three"); byte[] bytes = new byte[1024 * 1024]; @@ -793,7 +792,7 @@ public class ReplicationIT extends ConfigurableMacIT { UtilWaitThread.sleep(2000); } - for (int i = 0; i < 5; i++) { + for (int i = 0; i < 10; i++) { s = conn.createScanner(MetadataTable.NAME, Authorizations.EMPTY); s.fetchColumnFamily(LogColumnFamily.NAME); s.setRange(TabletsSection.getRange(tableId)); @@ -1500,7 +1499,7 @@ public class ReplicationIT extends ConfigurableMacIT { // We need the GC to close the file (CloseWriteAheadLogReferences) before we can remove the record log.info("Checking metadata table for replication entries"); foundResults = true; - for (int i = 0; i < 5; i++) { + for (int i = 0; i < 10; i++) { s = conn.createScanner(MetadataTable.NAME, Authorizations.EMPTY); s.setRange(ReplicationSection.getRange()); long size = 0; @@ -1512,7 +1511,7 @@ public class ReplicationIT extends ConfigurableMacIT { foundResults = false; break; } - Thread.sleep(1000); + Thread.sleep(2000); log.info(""); }
