diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java b/hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java index 16a264e06ddcd..4566b1f5cd6b1 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java @@ -480,7 +480,7 @@ private void processQueuedBlocksForInstant(Deque logBlocks, int } } // At this step the lastBlocks are consumed. We track approximate progress by number of log-files seen - progress = numLogFilesSeen - 1 / logFilePaths.size(); + progress = (numLogFilesSeen - 1) / logFilePaths.size(); } private ClosableIterator getRecordsIterator(HoodieDataBlock dataBlock, Option keySpecOpt) throws IOException {