From 008db9c5d2472b5ac1d94152a2a23e44ab69e2f4 Mon Sep 17 00:00:00 2001
From: Dom G <domgarguilo@apache.org>
Date: Mon, 14 Sep 2026 14:35:58 -0400
Subject: [PATCH] Set consistency level on batchwalk BatchScanner

---
 .../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 a9833df3..b5641df9 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 static void main(String[] args) throws Exception {
             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());