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());

Reply via email to