Apache Flink consists of a fault tolerance mechanism based on distributed checkpoints, and if there is a failure, the Flink program will resume processing from the last completed checkpoint upon its redemption.
Apache Flink includes a lightweight fault tolerance mechanism based on distributed checkpoints. In the case of a failure, a Flink program with checkpointing enabled will, upon recovery, resume processing from the last completed checkpoint, ensuring that Flink maintains exactly-once state semantics within an application. 
