You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2015/05/10 23:06:21 UTC
[3/9] accumulo git commit: ACCUMULO-3788 Recreate batchscanner in
ContinuousBatchWalker after its closed.
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/1.7
Commit: 757c1cb5569d02e6b155f1d5dd2f66f877ec0cd9
Parents: 671d4da
Author: Josh Elser <el...@apache.org>
Authored: Sat May 9 20:55:23 2015 -0400
Committer: Josh Elser <el...@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());