FlinkFlink 使用代码如何主动触发 SavePoint

Posted 2022-03-03 九师兄

文章目录

• 1.概述
• 2.案例
• • 2.1 主方法
  • 2.2 JobListener
  • 2.3 测试结果
• 3.源码
• • 3.1 测试类
  • 3.2 executeAsync
  • 3.3 checkpointCoordinator

1.概述

我们自定义了一个mysql source ，然后任务运行的时候回记录一些状态，但是检测点时间设置 5秒一次，但是我们程序3秒就执行完了，然后客户要求执行完毕就停止任务，不要一直运行，下次攒了一批数据后，web会调用这个flink让程序再次运行，所以要记录上次运行的位置，现在是放到检查点里面了，如何