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 <[email protected]>
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 {