FLinkFlink checkpoint 实现数据连续计算 恢复机制 拓扑图 变化 如何处理

Posted 2021-08-30 九师兄

1.概述

本博客是视频：Apache Flink 知其然，知其所以然（原理&实战） 的笔记。

改部分主要讲解了，当流任务失败后恢复，拓扑图改变了，这种情况下该怎么恢复checkpoint。

看到这个图，可以看到数据2个sink变成了一个。

2. 案例

2.1 普通业务

1.修改flink配置，实现本地集群，配置好检查点等信息，代码如下