[HUDI-2751] To avoid the duplicates for streaming read MOR table

• Type: Improvement
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 0.11.0, 0.12.0
• Component/s: Common Core
• Labels: release-0.14.0-blocker
• Story Points: 10
• Epic Link: Streaming Read
• Assignee: sivabalan narayanan
• Reporter: Danny Chen
• Created: 12/Nov/21 08:03
• Updated: 02/May/23 17:50
• Resolved: 01/May/23 03:40

Description

Imagine there are commits on the timeline:

                         -----delta-99 ----- commit 100(include 99 delta data set) ----- delta-101 ----- delta-102 -----
                          first read ->| second read ->
                         – range 1 ---| ----------------------range 2 -------------------|

instant 99, 101, 102 are successful non-compaction delta commits;
instant 100 is successful compaction instant.

The first inc read consumes to instant 99 and the second read consumes from instant 100 to instant 102, the second read would consumes the commit files of instant 100 which has already been consumed before.

The duplicate reading happens when this condition triggers: a compaction instant schedules then completes in one consume range.