Flink Checkpoints 深入解读存储选型、目录结构与“保留检查点”实战
1. Checkpoint 是什么:状态 + 位点的一致性快照开启 checkpointing 后,Flink 会周期性触发快照:
把 managed state 持久化
同时记录对应的 stream positions(例如 Kafka offset)
恢复时:
Job 从最新成功 checkpoint

