文档首页/ MapReduce服务 MRS/ 开发指南（普通版_2.x及之前）/ Flink开发指南/ 开发Flink应用/ 异步Checkpoint机制程序/ Flink异步Checkpoint应用开发思路
更新时间：2024-08-03 GMT+08:00
查看PDF
分享

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中。