Repository: accumulo Updated Branches: refs/heads/master ea076646b -> fe5fc3056
ACCUMULO-2476, ACCUMULO-2342 Sleep after we modify a constraint. -- cherry-picked d4b06999 back to 1.4 Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/6df83da6 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/6df83da6 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/6df83da6 Branch: refs/heads/master Commit: 6df83da60d594f66d147a479065ff51db73fb1a2 Parents: ea86b44 Author: Josh Elser <els...@apache.org> Authored: Sat Feb 8 16:10:53 2014 -0500 Committer: Eric Newton <eric.new...@gmail.com> Committed: Fri Mar 14 14:17:48 2014 -0400 ---------------------------------------------------------------------- .../src/test/java/org/apache/accumulo/proxy/SimpleTest.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/6df83da6/src/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java ---------------------------------------------------------------------- diff --git a/src/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java b/src/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java index 67b36a6..faaf3b7 100644 --- a/src/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java +++ b/src/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java @@ -613,6 +613,8 @@ public class SimpleTest { } catch (MutationsRejectedException e) {} client.removeConstraint(creds, TABLE_TEST, 1); + + UtilWaitThread.sleep(2000); writerOptions = new WriterOptions(); writerOptions.setLatencyMs(10000); @@ -641,6 +643,9 @@ public class SimpleTest { client.createTable(creds, TABLE_TEST, true, TimeType.MILLIS); // constraints client.addConstraint(creds, TABLE_TEST, NumericValueConstraint.class.getName()); + + UtilWaitThread.sleep(2000); + client.updateAndFlush(creds, TABLE_TEST, mutation("row1", "cf", "cq", "123")); try { @@ -649,6 +654,10 @@ public class SimpleTest { } catch (MutationsRejectedException ex) {} client.removeConstraint(creds, TABLE_TEST, 1); + + UtilWaitThread.sleep(2000); + + assertEquals(0, client.listConstraints(creds, TABLE_TEST).size()); client.updateAndFlush(creds, TABLE_TEST, mutation("row1", "cf", "cq", "x")); String scanner = client.createScanner(creds, TABLE_TEST, null); ScanResult more = client.nextK(scanner, 2);
