Flink狀態管理之checkPoint

簡介 一、state通常指一個具體的task/operator的狀態【state數據默認保存在java的堆內存中】，而checkpoint【能夠理解爲checkpoint是把state數據持久化存儲了】，則表示了一個Flink Job在一個特定時刻的一份全局狀態快照，即包含了全部task/operator的狀態java 注意：task是Flink中執行的基本單位。operator指算子(trans

>>阅读原文<<