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);

Reply via email to