ACCUMULO-378 Make sure to flush to get the entry written to metadata
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/f584685a Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/f584685a Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/f584685a Branch: refs/heads/ACCUMULO-378 Commit: f584685a5e6d5179b0366c044df9d4cb8622423a Parents: f247c8e Author: Josh Elser <els...@apache.org> Authored: Thu May 1 16:58:14 2014 -0400 Committer: Josh Elser <els...@apache.org> Committed: Thu May 1 16:58:14 2014 -0400 ---------------------------------------------------------------------- .../accumulo/test/replication/ReplicationSourceOnlyIT.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/f584685a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationSourceOnlyIT.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationSourceOnlyIT.java b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationSourceOnlyIT.java index ffb3ede..9d9021e 100644 --- a/test/src/test/java/org/apache/accumulo/test/replication/ReplicationSourceOnlyIT.java +++ b/test/src/test/java/org/apache/accumulo/test/replication/ReplicationSourceOnlyIT.java @@ -16,6 +16,7 @@ */ package org.apache.accumulo.test.replication; +import java.util.Arrays; import java.util.HashSet; import java.util.Iterator; import java.util.Map.Entry; @@ -169,6 +170,11 @@ public class ReplicationSourceOnlyIT extends ConfigurableMacIT { bw.close(); + // Force a write to metadata for the data written + for (String table : Arrays.asList(table1, table2, table3)) { + conn.tableOperations().flush(table, null, null, true); + } + keepRunning.set(false); t.join(5000);
