barrier) is periodically inserted into the data stream and flows with it as part of the data stream

Barriers are at the heart of Flink snapshots

A barrier compares the snapshot data of this cycle with the nextonePeriodic snapshot data is separated

When inserting barrierf, it will temporarily block the data flow