Flink Checkpoint/Savepoint對比
Flink 為作業(yè)的容錯提供 Checkpoint 和 Savepoint 兩種機制。保存點(diǎn)機制（Savepoints）是檢查點(diǎn)機制一種特殊的實(shí)現，它允許你通過(guò)手工方式來(lái)觸發(fā)Checkpoint，并將結果持久化存儲到指定路徑中，主要用于避免Flink集群在重啟或升級時(shí)導致?tīng)顟B(tài)丟失。
Savepoint 是一種特殊的 Checkpoint，實(shí)際上它們的存儲格式也是一致的，它們主要的不同在于定位。Checkpoint機制的目標在于保證Flink作業(yè)意外崩潰重啟不影響exactly once準確性，通常是配合作業(yè)重啟策略使用的。Checkpoint 是為 Flink runtime 準備的，Savepoint 是為 Flink 用戶(hù)準備的。因此 Checkpoint 是由 Flink runtime 定時(shí)觸發(fā)并根據運行配置自動(dòng)清理的，一般不需要用戶(hù)介入，而 Savepoint 的觸發(fā)和清理都由用戶(hù)掌控。
由于 Checkpoint 的頻率遠遠大于 Savepoint，Flink 對 Checkpoint 格式進(jìn)行了針對不同 StateBackend 的優(yōu)化，因此它在底層儲存效率更高，而代價(jià)是耦合性更強，比如不保證 擴容 （即改變作業(yè)并行度）的特性和跨版本兼容。
Savepoint 是全量的，不支持增量的。因為 Checkpoint 是秒級頻繁觸發(fā)的，兩個(gè)連續 Checkpoint 通常高度相似，因此對于 State 特別大的作業(yè)來(lái)說(shuō)，每次 Checkpoint 只增量地補充 diff 可以大大地節約成本，這就是 incremental Checkpoint 的由來(lái)。而 Savepoint 并不會(huì )連續地觸發(fā)，而且比起效率，Savepoint 更關(guān)注的是可移植性和版本兼容性。
評論
