Flink状态（state）管理在代码里配置checkpoint

checkPoint简介 为了保证state的容错性，Flink须要对state进行checkpoint。java Checkpoint是Flink实现容错机制最核心的功能，它可以根据配置周期性地基于Stream中各个Operator/task的状态来生成快照，从而将这些状态数据按期持久化存储下来，当Flink程序一旦意外崩溃时，从新运行程序时能够有选择地从这些快照进行恢复，从而修正由于故障带来的

>>阅读原文<<