Repository: accumulo Updated Branches: refs/heads/master 6ef85f9c5 -> a458a2fae
ACCUMULO-3051 give zookeeper updates time to propagate Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/a458a2fa Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/a458a2fa Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/a458a2fa Branch: refs/heads/master Commit: a458a2fae92fbd0239a1ebf243cf65f2ee3ff2f0 Parents: 4b03644 Author: Eric C. Newton <eric.new...@gmail.com> Authored: Thu Aug 7 11:38:31 2014 -0400 Committer: Eric C. Newton <eric.new...@gmail.com> Committed: Thu Aug 7 11:38:53 2014 -0400 ---------------------------------------------------------------------- .../replication/UnorderedWorkAssignerReplicationIT.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/a458a2fa/test/src/test/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java b/test/src/test/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java index 7ea7e32..5ad11c3 100644 --- a/test/src/test/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java +++ b/test/src/test/java/org/apache/accumulo/test/replication/UnorderedWorkAssignerReplicationIT.java @@ -147,6 +147,9 @@ public class UnorderedWorkAssignerReplicationIT extends ConfigurableMacIT { connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION.getKey(), "true"); connMaster.tableOperations().setProperty(masterTable, Property.TABLE_REPLICATION_TARGET.getKey() + peerClusterName, peerTableId); + // Wait for zookeeper updates (configuration) to propogate + UtilWaitThread.sleep(3 * 1000); + // Write some data to table1 BatchWriter bw = connMaster.createBatchWriter(masterTable, new BatchWriterConfig()); for (int rows = 0; rows < 5000; rows++) { @@ -311,6 +314,9 @@ public class UnorderedWorkAssignerReplicationIT extends ConfigurableMacIT { connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION.getKey(), "true"); connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION_TARGET.getKey() + peerClusterName, peerTableId2); + // Wait for zookeeper updates (configuration) to propogate + UtilWaitThread.sleep(3 * 1000); + // Write some data to table1 BatchWriter bw = connMaster.createBatchWriter(masterTable1, new BatchWriterConfig()); long masterTable1Records = 0l; @@ -573,6 +579,9 @@ public class UnorderedWorkAssignerReplicationIT extends ConfigurableMacIT { connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION.getKey(), "true"); connMaster.tableOperations().setProperty(masterTable2, Property.TABLE_REPLICATION_TARGET.getKey() + peerClusterName, peerTableId2); + // Wait for zookeeper updates (configuration) to propogate + UtilWaitThread.sleep(3 * 1000); + // Write some data to table1 BatchWriter bw = connMaster.createBatchWriter(masterTable1, new BatchWriterConfig()); for (int rows = 0; rows < 2500; rows++) {
