File tree Expand file tree Collapse file tree 4 files changed +7
-8
lines changed
hadoop-cloud-storage-project/hadoop-tos/src/main/java/org/apache/hadoop/fs/tosfs/util
hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-catalog/hadoop-yarn-applications-catalog-webapp Expand file tree Collapse file tree 4 files changed +7
-8
lines changed Original file line number Diff line number Diff line change 19
19
package org .apache .hadoop .fs .tosfs .util ;
20
20
21
21
import org .apache .hadoop .util .Preconditions ;
22
- import org .checkerframework .checker .nullness .qual .Nullable ;
22
+ import org .apache . hadoop . thirdparty . org . checkerframework .checker .nullness .qual .Nullable ;
23
23
24
24
import java .util .Iterator ;
25
25
import java .util .NoSuchElementException ;
Original file line number Diff line number Diff line change 99
99
import org .apache .hadoop .thirdparty .com .google .common .util .concurrent .ListeningExecutorService ;
100
100
import org .apache .hadoop .thirdparty .com .google .common .util .concurrent .MoreExecutors ;
101
101
import org .apache .hadoop .thirdparty .com .google .common .util .concurrent .ThreadFactoryBuilder ;
102
+ import org .apache .hadoop .thirdparty .org .checkerframework .checker .nullness .qual .NonNull ;
102
103
import org .apache .hadoop .conf .Configuration ;
103
104
import org .apache .hadoop .crypto .CryptoProtocolVersion ;
104
105
import org .apache .hadoop .fs .BatchedRemoteIterator .BatchedEntries ;
213
214
import org .apache .hadoop .tools .protocolPB .GetUserMappingsProtocolPB ;
214
215
import org .apache .hadoop .tools .protocolPB .GetUserMappingsProtocolServerSideTranslatorPB ;
215
216
import org .apache .hadoop .util .ReflectionUtils ;
216
- import org .checkerframework .checker .nullness .qual .NonNull ;
217
217
import org .slf4j .Logger ;
218
218
import org .slf4j .LoggerFactory ;
219
219
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
}
Original file line number Diff line number Diff line change 20
20
"apidoc" : " 0.17.7"
21
21
},
22
22
"resolutions" : {
23
+ "color" : " 3.1.3" ,
23
24
"triple-beam" : " 1.3.0"
24
25
},
25
26
"scripts" : {
You can’t perform that action at this time.
0 commit comments