Thanks David, it’s clear now.
In my case, the x2 will be recovered by the last checkpoint if it was processed
and wait few seconds to be checkpointed Or my source can be rewind and it will
replay the x2.
> 2022年7月12日 09:10，David Anderson 写道：
>
> This is, in fact, the expected behavior. Let
This is, in fact, the expected behavior. Let me explain why:
In order for Flink to provide exactly-once guarantees, the input sources
must be able to rewind and then replay any events since the last checkpoint.
In the scenario you shared, the last checkpoint was checkpoint 2, which
occurred befor
