This is an automated email from the ASF dual-hosted git repository.

garyli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 997200f27f [MINOR] fix progress field calculate logic in 
HoodieLogRecordReader (#6291)
997200f27f is described below

commit 997200f27f5ad64c11bc7b6dedc01ca4c898c890
Author: flashJd <47289...@qq.com>
AuthorDate: Mon Aug 15 16:02:11 2022 +0800

    [MINOR] fix progress field calculate logic in HoodieLogRecordReader (#6291)
---
 .../org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 16a264e06d..4566b1f5cd 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 @@ public abstract class AbstractHoodieLogRecordReader {
       }
     }
     // 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 {

Reply via email to