@@ -145,7 +145,8 @@ public static BlockInStream create(FileSystemContext context, BlockInfo info,
145145 + "data locates in the local worker {}, shortCircuitEnabled {}, "
146146 + "shortCircuitPreferred {}, sourceSupportDomainSocket {}, enablePrefetchRead {})" ,
147147 blockId , dataSource , NetworkAddressUtils .getClientHostName (alluxioConf ), dataSource ,
148- sourceIsLocal , shortCircuit , shortCircuitPreferred , sourceSupportsDomainSocket , enablePrefetchRead );
148+ sourceIsLocal , shortCircuit , shortCircuitPreferred , sourceSupportsDomainSocket ,
149+ enablePrefetchRead );
149150 return createGrpcBlockInStream (context , dataSource , dataSourceType , blockId ,
150151 blockSize , options );
151152 }
@@ -289,8 +290,8 @@ protected BlockInStream(DataReader.Factory dataReaderFactory,
289290 * @param enablePrefetchRead whether to enable prefetch
290291 */
291292 @ VisibleForTesting
292- protected BlockInStream (DataReader .Factory dataReaderFactory ,
293- WorkerNetAddress address , BlockInStreamSource blockSource , long id , long length , boolean enablePrefetchRead ) {
293+ protected BlockInStream (DataReader .Factory dataReaderFactory , WorkerNetAddress address ,
294+ BlockInStreamSource blockSource , long id , long length , boolean enablePrefetchRead ) {
294295 this (dataReaderFactory , address , blockSource , id , length );
295296 mEnablePrefetchRead = enablePrefetchRead ;
296297 }
0 commit comments