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

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

commit dfe9ab4692f7f2fd56e592c6c4f6595e33f5f272
Merge: 8699e3ed52 3c12ac6e3d
Author: Dave Marion <[email protected]>
AuthorDate: Wed Jul 29 12:40:12 2026 +0000

    Merge branch '2.1'

 .../main/java/org/apache/accumulo/core/file/FileOperations.java  | 8 --------
 .../accumulo/core/file/blockfile/impl/CachableBlockFile.java     | 9 +++++++++
 2 files changed, 9 insertions(+), 8 deletions(-)

diff --cc 
core/src/main/java/org/apache/accumulo/core/file/blockfile/impl/CachableBlockFile.java
index e445da175a,191c260c0b..39ee8efcf8
--- 
a/core/src/main/java/org/apache/accumulo/core/file/blockfile/impl/CachableBlockFile.java
+++ 
b/core/src/main/java/org/apache/accumulo/core/file/blockfile/impl/CachableBlockFile.java
@@@ -49,7 -52,9 +49,8 @@@ import org.apache.hadoop.fs.Path
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
 +import com.github.benmanes.caffeine.cache.Cache;
+ import com.google.common.base.Preconditions;
 -import com.google.common.cache.Cache;
  
  /**
   * This is a wrapper class for BCFile that includes a cache for independent 
caches for datablocks
@@@ -116,7 -126,9 +121,9 @@@ public class CachableBlockFile 
        return this;
      }
  
 -    public CachableBuilder input(InputStream is, String cacheId) {
 +    public CachableBuilder input(FSDataInputStream is, String cacheId) {
+       Preconditions.checkState(this.inputSupplier == null,
+           "file input already set via call to fsPath()");
        this.cacheId = cacheId;
        this.inputSupplier = () -> is;
        return this;

Reply via email to