Flink狀態（state）管理在代碼裏配置checkpoint

checkPoint簡介 爲了保證state的容錯性，Flink須要對state進行checkpoint。java Checkpoint是Flink實現容錯機制最核心的功能，它可以根據配置週期性地基於Stream中各個Operator/task的狀態來生成快照，從而將這些狀態數據按期持久化存儲下來，當Flink程序一旦意外崩潰時，從新運行程序時能夠有選擇地從這些快照進行恢復，從而修正由於故障帶來的

>>阅读原文<<