Apache Flink includes a lightweight fault tolerance mechanism based on distributed checkpoints, and in the case of a failure, a Flink program with checkpointing enabled will, upon recovery, resume processing from the last completed checkpoint.
Apache Flink includes a lightweight fault tolerance mechanism based on distributed checkpoints, and in the case of a failure, a Flink program with checkpointing enabled will, upon recovery, resume processing from the last completed checkpoint.