ACCUMULO-3788 Recreate batchscanner in ContinuousBatchWalker after its closed.
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/757c1cb5 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/757c1cb5 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/757c1cb5 Branch: refs/heads/master Commit: 757c1cb5569d02e6b155f1d5dd2f66f877ec0cd9 Parents: 671d4da Author: Josh Elser <els...@apache.org> Authored: Sat May 9 20:55:23 2015 -0400 Committer: Josh Elser <els...@apache.org> Committed: Sat May 9 20:55:23 2015 -0400 ---------------------------------------------------------------------- .../apache/accumulo/test/continuous/ContinuousBatchWalker.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/757c1cb5/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousBatchWalker.java ---------------------------------------------------------------------- diff --git a/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousBatchWalker.java b/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousBatchWalker.java index 5c54b08..2c32176 100644 --- a/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousBatchWalker.java +++ b/test/src/main/java/org/apache/accumulo/test/continuous/ContinuousBatchWalker.java @@ -63,10 +63,10 @@ public class ContinuousBatchWalker { Scanner scanner = ContinuousUtil.createScanner(conn, clientOpts.getTableName(), auths); scanner.setBatchSize(scanOpts.scanBatchSize); - BatchScanner bs = conn.createBatchScanner(clientOpts.getTableName(), auths, bsOpts.scanThreads); - bs.setTimeout(bsOpts.scanTimeout, TimeUnit.MILLISECONDS); - while (true) { + BatchScanner bs = conn.createBatchScanner(clientOpts.getTableName(), auths, bsOpts.scanThreads); + bs.setTimeout(bsOpts.scanTimeout, TimeUnit.MILLISECONDS); + Set<Text> batch = getBatch(scanner, opts.min, opts.max, scanOpts.scanBatchSize, r); List<Range> ranges = new ArrayList<Range>(batch.size());
