From 7590124a07d69af06406472296ac5cce99a2cc1d Mon Sep 17 00:00:00 2001 From: flashJd <47289660@qq.com> Date: Fri, 12 Aug 2022 22:10:46 +0800 Subject: [PATCH] [MINOR] fix progress field calculate logic in HoodieLogRecordReader --- .../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 16a264e06ddcd..4566b1f5cd6b1 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 @@ private void processQueuedBlocksForInstant(Deque 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 getRecordsIterator(HoodieDataBlock dataBlock, Option keySpecOpt) throws IOException {