[MINOR] fix progress field calculate logic in HoodieLogRecordReader (a…

…pache#6291)
TengHuo · Oct 7, 2022 · ca911e9 · ca911e9
1 parent 661a0a7
commit ca911e9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java b/...-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java
@@ -480,7 +480,7 @@ private void processQueuedBlocksForInstant(Deque<HoodieLogBlock> 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<IndexedRecord> getRecordsIterator(HoodieDataBlock dataBlock, Option<KeySpec> keySpecOpt) throws IOException {