Hello, I'm trying to understand the process of checkpoint processing for exact-once in Flink, and I have some doubts.
The documentation says that when there is a failure and the state of an operator is restored, the already processed records are deleted based on their identifiers. My doubts is, how these identifiers between two checkpoints are maintained? Every time a new input record comes to the stateful operator, Flink persists it before making the checkpoint? Otherwise, there may be messages to reprocess after a failure. Thanks !!!
