Flink开启Checkpoint样例程序开发思路

场景说明

假定用户需要每隔1秒钟需要统计4秒中窗口中数据的量，并做到状态严格一致性，即：当应用出现异常并恢复后，各个算子的状态能够处于统一的状态。

数据规划

1. 使用自定义算子每秒钟产生大约10000条数据。
2. 产生的数据为一个四元组（Long，String，String，Integer）。
3. 数据经统计后，统计结果打印到终端输出。
4. 打印输出的结果为Long类型的数据。

开发思路

1. source算子每隔1秒钟发送10000条数据，并注入到Window算子中。
2. window算子每隔1秒钟统计一次最近4秒钟内数据数量。
3. 每隔1秒钟将统计结果打印到终端。具体查看方式请参考查看Flink应用调测结果。
4. 每隔6秒钟触发一次checkpoint，然后将checkpoint的结果保存到HDFS中。