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 {