Skip to content
Permalink
Browse files
[MINOR] fix progress field calculate logic in HoodieLogRecordReader (#…
  • Loading branch information
flashJd committed Aug 15, 2022
1 parent 553e280 commit 997200f27f5ad64c11bc7b6dedc01ca4c898c890
Showing 1 changed file with 1 addition and 1 deletion.
@@ -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 {

0 comments on commit 997200f

Please sign in to comment.