diff --git a/dora/tests/integration/src/test/java/alluxio/client/hadoop/DFSIOIntegrationTest.java b/dora/tests/integration/src/test/java/alluxio/client/hadoop/DFSIOIntegrationTest.java index f4db64595869..d58cab2e817b 100644 --- a/dora/tests/integration/src/test/java/alluxio/client/hadoop/DFSIOIntegrationTest.java +++ b/dora/tests/integration/src/test/java/alluxio/client/hadoop/DFSIOIntegrationTest.java @@ -660,7 +660,8 @@ public Closeable getIOStream(String name) throws IOException { public Long doIO(Reporter reporter, String name, long totalSize) throws IOException { PositionedReadable in = (PositionedReadable) this.mStream; long actualSize = 0; - for (long pos = nextOffset(-1); actualSize < totalSize && pos < totalSize; pos = nextOffset(pos)) { + for (long pos = nextOffset(-1); actualSize < totalSize + && pos < totalSize; pos = nextOffset(pos)) { int curSize = in.read(pos, mBuffer, 0, mBufferSize); if (curSize < 0) { break;