This is an automated email from the ASF dual-hosted git repository.
keith-turner 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 4f7bde196a Removed openFile wait loop (#6618)
4f7bde196a is described below
commit 4f7bde196ae6774176741fe1d4a3fac3c0c7d6c6
Author: Keith Turner <[email protected]>
AuthorDate: Wed Oct 28 14:16:08 2026 -0400
Removed openFile wait loop (#6618)
Same change as in #6493
---
.../apache/accumulo/core/client/rfile/RFileScannerBuilder.java | 8 --------
1 file changed, 8 deletions(-)
diff --git
a/core/src/main/java/org/apache/accumulo/core/client/rfile/RFileScannerBuilder.java
b/core/src/main/java/org/apache/accumulo/core/client/rfile/RFileScannerBuilder.java
index 64d77d2c52..1abb1ddb58 100644
---
a/core/src/main/java/org/apache/accumulo/core/client/rfile/RFileScannerBuilder.java
+++
b/core/src/main/java/org/apache/accumulo/core/client/rfile/RFileScannerBuilder.java
@@ -64,14 +64,6 @@ class RFileScannerBuilder implements RFile.InputArguments,
RFile.ScannerFSOption
FileStatus status = fs.getFileStatus(paths[i]);
CompletableFuture<FSDataInputStream> future =
fs.openFile(paths[i]).withFileStatus(status).build();
- while (!future.isDone()) {
- try {
- Thread.sleep(10);
- } catch (InterruptedException e) {
- Thread.currentThread().interrupt();
- throw new IOException("Interrupted while opening file: " +
paths[i], e);
- }
- }
try {
FSDataInputStream is = future.get();
sources[i] = new RFileSource(is, status.getLen());