1.概述 2.案例
2.1 主方法 2.2 JobListener 2.3 测试结果 3.源码
3.1 测试类
3.2 executeAsync
3.3 checkpointCoordinator
我们自定义了一个MySQL source ，然后任务运行的时候回记录一些状态，但是检测点时间设置 5秒一次，但是我们程序3秒就执行完了，然后客户要求执行完毕就停止任务，不要一直运行，下次攒了一批数据后，web会调用这个flink让程序再次运行，所以要记录上次运行的位置，现在是放到检查点里面了，如何
