Flink組件二：checkpoint

2.Checkpoint 2.1. 狀態的保存和修復 checkpoint 定時製作分佈式快照，對程序中的狀態進行備份 發生故障時： 將整個作業的所有task都回滾到最後一次成功checkpoint中的狀態，然後從那個點開始處理 必要條件： 數據源支持重發 一致性語義： 恰好一次 至少一次 StreamExecutionEnvironment env = StreamExecutionEnviro

>>阅读原文<<