accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [2/6] git commit: ACCUMULO-2342 Sleep after we modify a constraint.
Date Sat, 08 Feb 2014 22:28:26 GMT
ACCUMULO-2342 Sleep after we modify a constraint.

We have to wait for the watcher on zk to trigger and propagate down to
the constraint observer so that the mutations won't be incorrectly
rejected and fail these unit tests.


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/d4b06999
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/d4b06999
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/d4b06999

Branch: refs/heads/1.6.0-SNAPSHOT
Commit: d4b06999694fc1238fad0a19fd6544520b44a620
Parents: b930321
Author: Josh Elser <elserj@apache.org>
Authored: Sat Feb 8 16:10:53 2014 -0500
Committer: Josh Elser <elserj@apache.org>
Committed: Sat Feb 8 16:10:53 2014 -0500

----------------------------------------------------------------------
 .../src/test/java/org/apache/accumulo/proxy/SimpleTest.java  | 8 ++++++++
 1 file changed, 8 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/d4b06999/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java
----------------------------------------------------------------------
diff --git a/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java b/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java
index 9dab290..5573d20 100644
--- a/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java
+++ b/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java
@@ -934,6 +934,8 @@ public class SimpleTest {
     } catch (MutationsRejectedException e) {}
     
     client.removeConstraint(creds, TABLE_TEST, 1);
+
+    UtilWaitThread.sleep(2000);
     
     writerOptions = new WriterOptions();
     writerOptions.setLatencyMs(10000);
@@ -962,6 +964,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 {
@@ -970,6 +975,9 @@ 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);


Mime
View raw message