增量式Checkpoint實驗(碰到bug沒有搞定)

根據[1]: '''這裏面的核心就是 checkpoint 機制，Flink 使用 checkpoint 機制來進行狀態保證，在 Flink 中 checkpoint 是一個定時觸發的全局異步快照，並持久化到持久存儲系統上（通常是分佈式文件系統）。發生故障後，Flink 選擇從最近的一個快照進行恢復。有用戶的作業狀態達到 GB 甚至 TB 級別，對這麼大的作業狀態做一次 checkpoint 會非

>>阅读原文<<