Flink全表扫描后读取 binlog 时发生异常后怎么恢复？

1.若源 MySQL 异常，Flink Task 发现无法连接数据库异常退出，重新启动 Flink Task（或者 retry），将会从最近一次 Checkpoint 的数据进行恢复，由于可以读取到 mysql binlog 位点 信息，实现继续同步，不会丢失数据，最终也能保持一致性。

2.若 Flink 任务异常，重新启动或 retry 后，同场景 1 一致，继续读取 binlog，能保持一致性。

3.若目的 MySQL 异常，JDBC connector 无法往目标数据库写入，CDC connector 读取到的 binlog 位点信息也不再更新，两个操作是一个原子性操作，在 Flink Task 恢复后，从最近一 次 Checkpoint 进行恢复，最终保持一致性。

资料来源：《Flink CDC：新一代数据集成框架》，下载链接：https://developer.aliyun.com/topic/download?id=8256。