File tree Expand file tree Collapse file tree 1 file changed +4
-6
lines changed
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services Expand file tree Collapse file tree 1 file changed +4
-6
lines changed Original file line number Diff line number Diff line change @@ -184,13 +184,11 @@ public AbfsInputStream(
184
184
* If none of the V1 and V2 are enabled, then no read ahead will be done.
185
185
*/
186
186
if (readAheadV2Enabled ) {
187
- ReadBufferManagerV2 .setReadBufferManagerConfigs (
188
- readAheadBlockSize , client .getAbfsConfiguration ());
189
- readBufferManager = ReadBufferManagerV2 .getBufferManager ();
190
- } else {
191
- ReadBufferManagerV1 .setReadBufferManagerConfigs (readAheadBlockSize );
192
- readBufferManager = ReadBufferManagerV1 .getBufferManager ();
187
+ LOG .debug ("ReadBufferManagerV2 not yet implemented, defaulting to ReadBufferManagerV1" );
193
188
}
189
+ ReadBufferManagerV1 .setReadBufferManagerConfigs (readAheadBlockSize );
190
+ readBufferManager = ReadBufferManagerV1 .getBufferManager ();
191
+
194
192
if (streamStatistics != null ) {
195
193
ioStatistics = streamStatistics .getIOStatistics ();
196
194
}
You can’t perform that action at this time.
0 commit comments