Repository: accumulo Updated Branches: refs/heads/1.6.0-SNAPSHOT d896bf37d -> 09388f567
ACCUMULO-2584 use IteratorSettings to push the scan iterator, not a zookeeper setting Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/09388f56 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/09388f56 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/09388f56 Branch: refs/heads/1.6.0-SNAPSHOT Commit: 09388f5671a3979c3c83c5de8f63eb55a3e83fcb Parents: d896bf3 Author: Eric C. Newton <eric.new...@gmail.com> Authored: Wed Apr 2 11:02:37 2014 -0400 Committer: Eric C. Newton <eric.new...@gmail.com> Committed: Wed Apr 2 11:02:37 2014 -0400 ---------------------------------------------------------------------- .../src/test/java/org/apache/accumulo/test/ShellServerIT.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/09388f56/test/src/test/java/org/apache/accumulo/test/ShellServerIT.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/accumulo/test/ShellServerIT.java b/test/src/test/java/org/apache/accumulo/test/ShellServerIT.java index 87288c7..1a0ef5b 100644 --- a/test/src/test/java/org/apache/accumulo/test/ShellServerIT.java +++ b/test/src/test/java/org/apache/accumulo/test/ShellServerIT.java @@ -41,6 +41,7 @@ import jline.console.ConsoleReader; import org.apache.accumulo.core.Constants; import org.apache.accumulo.core.client.Connector; +import org.apache.accumulo.core.client.IteratorSetting; import org.apache.accumulo.core.client.Scanner; import org.apache.accumulo.core.client.TableNotFoundException; import org.apache.accumulo.core.client.admin.TableOperations; @@ -58,6 +59,7 @@ import org.apache.accumulo.core.util.UtilWaitThread; import org.apache.accumulo.core.util.shell.Shell; import org.apache.accumulo.test.functional.FunctionalTestUtils; import org.apache.accumulo.test.functional.SimpleMacIT; +import org.apache.accumulo.test.functional.SlowIterator; import org.apache.accumulo.tracer.TraceServer; import org.apache.commons.io.FileUtils; import org.apache.commons.lang.StringUtils; @@ -994,10 +996,11 @@ public class ShellServerIT extends SimpleMacIT { for (int i = 0; i < 6; i++) { ts.exec("insert " + i + " cf cq value", true); } - ts.exec("config -t " + table + " -s table.iterator.scan.slow=30,org.apache.accumulo.test.functional.SlowIterator", true); - ts.exec("config -t " + table + " -s table.iterator.scan.slow.opt.sleepTime=500", true); Connector connector = getConnector(); final Scanner s = connector.createScanner(table, Authorizations.EMPTY); + IteratorSetting cfg = new IteratorSetting(30, SlowIterator.class); + SlowIterator.setSleepTime(cfg, 500); + s.addScanIterator(cfg); Thread thread = new Thread() { @Override
