主节点错误重启后，Flink 批次作业如何恢复执行进度？-使用 Flink 的影响

以下是一个 JM 出错重启后进度恢复的效果示例。

该批作业的拓扑结构为 Source -> Map -> Sink ，当作业运行到 Map 节点时，因为外部服务的原因导致 JM 所在机器下线，从而造成了 JM failover。

随后，高可用服务将会自动拉起新的 JM 进程，作业将进入 RECONCILING 状态，表示作业进入了恢复运行进展的阶段。

当作业恢复完成后，将进入 RUNNING 状态。

点进作业详情页后，可以观察到作业已经恢复到 JM failover 前到进展了。