From 9bd8e7900628d1c378b475e380a3a499a134f43f Mon Sep 17 00:00:00 2001 From: Anuj Modi Date: Tue, 7 Oct 2025 15:24:37 +0530 Subject: [PATCH] HADOOP-19710. [ABFS] Read Buffer Manager V2 should not be allowed untill implemented Contributed by Anuj Modi --- .../hadoop/fs/azurebfs/services/AbfsInputStream.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsInputStream.java b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsInputStream.java index 38b49603fbb00..ba2bb61802a08 100644 --- a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsInputStream.java +++ b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsInputStream.java @@ -184,13 +184,11 @@ public AbfsInputStream( * If none of the V1 and V2 are enabled, then no read ahead will be done. */ if (readAheadV2Enabled) { - ReadBufferManagerV2.setReadBufferManagerConfigs( - readAheadBlockSize, client.getAbfsConfiguration()); - readBufferManager = ReadBufferManagerV2.getBufferManager(); - } else { - ReadBufferManagerV1.setReadBufferManagerConfigs(readAheadBlockSize); - readBufferManager = ReadBufferManagerV1.getBufferManager(); + LOG.debug("ReadBufferManagerV2 not yet implemented, defaulting to ReadBufferManagerV1"); } + ReadBufferManagerV1.setReadBufferManagerConfigs(readAheadBlockSize); + readBufferManager = ReadBufferManagerV1.getBufferManager(); + if (streamStatistics != null) { ioStatistics = streamStatistics.getIOStatistics(); }