ent checkpoint vs. the set that goes into the next checkpoint) into the data stream.</p>
<p>The barrier is passed from operator to operator. For every operator, it triggers the operator&rsquo;s state backend to take a snapshot of its state.</p>
<center>
<img src="/img/blog/eo-post-graphic-2.png" width="600px" alt="A sample Flink application - precommit"/>
</center>
<p>The data source stores its Kafka offsets, and after completing this, it passes the checkpoint barrier to the next operator.</p>
<p>This appro