(accumulo-testing) branch main updated: Set consistency level on batchwalk BatchScanner (#315)

[domgarguilo]

This is an automated email from the ASF dual-hosted git repository.

DomGarguilo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo-testing.git


The following commit(s) were added to refs/heads/main by this push:
     new 641d8c7  Set consistency level on batchwalk BatchScanner (#315)
641d8c7 is described below

commit 641d8c7c556c25d187893cb9e706c79f530ce2b5
Author: Dom G. <domgargu...@apache.org>
AuthorDate: Wed Sep 16 11:15:28 2026 -0400

    Set consistency level on batchwalk BatchScanner (#315)
---
 .../org/apache/accumulo/testing/continuous/ContinuousBatchWalker.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/src/main/java/org/apache/accumulo/testing/continuous/ContinuousBatchWalker.java
 
b/src/main/java/org/apache/accumulo/testing/continuous/ContinuousBatchWalker.java
index a9833df..b5641df 100644
--- 
a/src/main/java/org/apache/accumulo/testing/continuous/ContinuousBatchWalker.java
+++ 
b/src/main/java/org/apache/accumulo/testing/continuous/ContinuousBatchWalker.java
@@ -65,6 +65,7 @@ public class ContinuousBatchWalker {
             
Duration.ofMillis(Integer.parseInt(env.getTestProperty(TestProps.CI_BW_SLEEP_MS)));
         while (true) {
           try (BatchScanner bs = 
client.createBatchScanner(env.getAccumuloTableName(), auths)) {
+            bs.setConsistencyLevel(cl);
             Set<Text> batch =
                 getBatch(scanner, env.getRowMin(), env.getRowMax(), 
scanBatchSize, env.getRandom());
             List<Range> ranges = 
batch.stream().map(Range::new).collect(Collectors.toList());