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