You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2014/03/14 19:19:04 UTC
git commit: ACCUMULO-2476,
ACCUMULO-2342 Sleep after we modify a constraint. -- cherry-picked
d4b06999 back to 1.4
Repository: accumulo
Updated Branches:
refs/heads/1.4.5-SNAPSHOT ea86b44df -> 6df83da60
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/1.4.5-SNAPSHOT
Commit: 6df83da60d594f66d147a479065ff51db73fb1a2
Parents: ea86b44
Author: Josh Elser <el...@apache.org>
Authored: Sat Feb 8 16:10:53 2014 -0500
Committer: Eric Newton <er...@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);