第 22 節 Flink 狀態、恢復、快照

上篇：第 21 節　Flink Distributed Cache(分佈式緩存) 1、Flink 狀態(State)管理與恢復 （1）狀態(State) 我們前面寫的wordcount的例子，沒有包含狀態管理。如果一個task在處理過程中掛掉了，那麼它在內存中的狀態都會丟失，所有的數據都需要重新計算。從容錯和消息處理的語義上(at least once, exactly once)，Flink引入

>>阅读原文<<