Flink State狀態以及Checkpoint機制(二)

在上篇文章中介紹瞭如何Flink的State狀態,本篇文章接着上篇文章繼續介紹Flink的Checkpoint機制。啓動checkpoint機制它能夠爲每個job備份了一份快照,當job遇到故障重啓或者失敗的時候,咱們就沒必要從每一個job的源頭去從新計算,而是從最近的一個完整的checkpoint開始恢復,避免了重複計算,節省了資源,而且保證了Exactly Once 語義。具體的使用方法以及實
相關文章
相關標籤/搜索