accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [4/9] accumulo git commit: ACCUMULO-3788 Recreate batchscanner in ContinuousBatchWalker after its closed.
Date Sun, 10 May 2015 21:06:22 GMT
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 <elserj@apache.org>
Authored: Sat May 9 20:55:23 2015 -0400
Committer: Josh Elser <elserj@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());
 


Mime
View raw message