Checkpoints

Barriers, alignment, snapshots, recovery — the distributed snapshot problem, and Flink's answer to it

The module the course is built around. A checkpoint is a consistent cut across every operator's state and every source's position, drawn by barriers that flow with the records. You kill a TaskManager between checkpoints and watch state restore to checkpoint k and Kafka rewind to S_k: per-tenant totals neither lost nor double-counted inside Flink.

Estimated time: 105 minutes

Stuck on something? The AI tutor sees this lecture—just ask.