From bc356262478fb82c786dc3bee7c312b2b1a29634 Mon Sep 17 00:00:00 2001 From: Anuj Modi Date: Mon, 29 Sep 2025 01:56:52 -0700 Subject: [PATCH] Do not init RBMV1 --- .../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(); }