[MINOR] fix progress field calculate logic in HoodieLogRecordReader

flashJd · flashJd · commit 7590124a07d6 · 2022-08-12T22:10:46.000+08:00
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
@@ -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 {

Original file line number	Diff line number	Diff line change
`@@ -480,7 +480,7 @@ private void processQueuedBlocksForInstant(Deque<HoodieLogBlock> logBlocks, int`
`480`	`480`	`}`
`481`	`481`	`}`
`482`	`482`	`// At this step the lastBlocks are consumed. We track approximate progress by number of log-files seen`
`483`		`- progress = numLogFilesSeen - 1 / logFilePaths.size();`
	`483`	`+ progress = (numLogFilesSeen - 1) / logFilePaths.size();`
`484`	`484`	`}`
`485`	`485`
`486`	`486`	`private ClosableIterator<IndexedRecord> getRecordsIterator(HoodieDataBlock dataBlock, Option<KeySpec> keySpecOpt) throws IOException {`