GitHub user danny0405 added a comment to the discussion: RLI support for Flink streaming
The barrier is flowing together with the records in Flink, see [how-does-state-snapshotting-work](https://nightlies.apache.org/flink/flink-docs-master/docs/learn-flink/fault_tolerance/#how-does-state-snapshotting-work), when the `BucketAssignor` received a record, it emits both the data records and index records in one `#processElement` call, so we can always keep the bindings of these two, in other words, no barrier would be between these two. GitHub link: https://github.com/apache/hudi/discussions/17452#discussioncomment-15227062 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
