diff --git a/core/client/fs/src/main/java/alluxio/client/block/stream/BlockInStream.java b/core/client/fs/src/main/java/alluxio/client/block/stream/BlockInStream.java index 134adce56a01..e3a70c09703b 100644 --- a/core/client/fs/src/main/java/alluxio/client/block/stream/BlockInStream.java +++ b/core/client/fs/src/main/java/alluxio/client/block/stream/BlockInStream.java @@ -145,7 +145,8 @@ public static BlockInStream create(FileSystemContext context, BlockInfo info, + "data locates in the local worker {}, shortCircuitEnabled {}, " + "shortCircuitPreferred {}, sourceSupportDomainSocket {}, enablePrefetchRead {})", blockId, dataSource, NetworkAddressUtils.getClientHostName(alluxioConf), dataSource, - sourceIsLocal, shortCircuit, shortCircuitPreferred, sourceSupportsDomainSocket, enablePrefetchRead); + sourceIsLocal, shortCircuit, shortCircuitPreferred, sourceSupportsDomainSocket, + enablePrefetchRead); return createGrpcBlockInStream(context, dataSource, dataSourceType, blockId, blockSize, options); } @@ -289,8 +290,8 @@ protected BlockInStream(DataReader.Factory dataReaderFactory, * @param enablePrefetchRead whether to enable prefetch */ @VisibleForTesting - protected BlockInStream(DataReader.Factory dataReaderFactory, - WorkerNetAddress address, BlockInStreamSource blockSource, long id, long length, boolean enablePrefetchRead) { + protected BlockInStream(DataReader.Factory dataReaderFactory, WorkerNetAddress address, + BlockInStreamSource blockSource, long id, long length, boolean enablePrefetchRead) { this(dataReaderFactory, address, blockSource, id, length); mEnablePrefetchRead = enablePrefetchRead; }