GitHub user vinothchandar added a comment to the discussion: RLI support for Flink streaming
@bhasudha 's question: how do we ensure the checkpoint will always have the corresponding index record to a data record and vice-versa? e.g: ` [r4 r3 r2 r1 ] => BucketAssignor => [ ir4 dr4 ir3 dr3 ir2 dr2 ir1 dr1]` What prevents the checkpoint barrier from being placed like this: `[ ir4 dr4 ir3 dr3 ir2 <checkpoint barrier> dr2 ir1 dr1]` GitHub link: https://github.com/apache/hudi/discussions/17452#discussioncomment-15226686 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
