Updated Branches: refs/heads/master ccf988546 -> 77760cf7e
ACCUMULO-1672 avoid race condition when setting constraints in proxy test Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/77760cf7 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/77760cf7 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/77760cf7 Branch: refs/heads/master Commit: 77760cf7e423358883c55119099e11e17122e8cc Parents: ccf9885 Author: Keith Turner <[email protected]> Authored: Tue Sep 10 16:18:29 2013 -0400 Committer: Keith Turner <[email protected]> Committed: Tue Sep 10 16:19:27 2013 -0400 ---------------------------------------------------------------------- proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/77760cf7/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 b98cf31..b0d660d 100644 --- a/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java +++ b/proxy/src/test/java/org/apache/accumulo/proxy/SimpleTest.java @@ -938,6 +938,7 @@ public class SimpleTest { client.createTable(creds, TABLE_TEST, true, TimeType.MILLIS); // constraints client.addConstraint(creds, TABLE_TEST, NumericValueConstraint.class.getName()); + assertEquals(2, client.listConstraints(creds, TABLE_TEST).size()); client.updateAndFlush(creds, TABLE_TEST, mutation("row1", "cf", "cq", "123")); try { @@ -946,6 +947,7 @@ public class SimpleTest { } catch (MutationsRejectedException ex) {} client.removeConstraint(creds, TABLE_TEST, 2); + assertEquals(1, 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);
