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

krathbun pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/2.1 by this push:
     new 9ffe92b885 fix an incorrect call in ClientSideIteratorScanner (#6036)
9ffe92b885 is described below

commit 9ffe92b885de29c0c0b36fdc530db850f29d17dc
Author: Kevin Rathbun <[email protected]>
AuthorDate: Mon Dec 22 22:26:09 2025 -0500

    fix an incorrect call in ClientSideIteratorScanner (#6036)
    
    `batchTimeout` was set to `scanner.getTimeout(MILLISECONDS)` instead of 
`scanner.getBatchTimeout(MILLISECONDS)`
---
 .../java/org/apache/accumulo/core/client/ClientSideIteratorScanner.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/core/src/main/java/org/apache/accumulo/core/client/ClientSideIteratorScanner.java
 
b/core/src/main/java/org/apache/accumulo/core/client/ClientSideIteratorScanner.java
index 0209e8deec..48fb306c86 100644
--- 
a/core/src/main/java/org/apache/accumulo/core/client/ClientSideIteratorScanner.java
+++ 
b/core/src/main/java/org/apache/accumulo/core/client/ClientSideIteratorScanner.java
@@ -177,7 +177,7 @@ public class ClientSideIteratorScanner extends 
ScannerOptions implements Scanner
     this.range = scanner.getRange();
     this.size = scanner.getBatchSize();
     this.retryTimeout = scanner.getTimeout(MILLISECONDS);
-    this.batchTimeout = scanner.getTimeout(MILLISECONDS);
+    this.batchTimeout = scanner.getBatchTimeout(MILLISECONDS);
     this.readaheadThreshold = scanner.getReadaheadThreshold();
     SamplerConfiguration samplerConfig = scanner.getSamplerConfiguration();
     if (samplerConfig != null) {

Reply via email to