Flink基础教程

有状态的计算

｜

59

位置1

位置2 位置3

恢复位置及状态值

图 5-8：Flink 将输入流倒回到上一个检查点屏障的位置，同时恢复

map

算子的状态值。

然后，Flink 从此处开始重新处理。这样做保证了在记录被处理之后，

map

算子的状

态值与没有发生故障时的一致

Flink

检查点算法的正式名称是

异步屏障快照

（

asynchronous barrier snapshotting

）。

该算法大致基于

Chandy-Lamport

分布式快照算法。

5.3

　保存点

：

状态版本控制

检查点由

Flink

自动生成，用来在故障发生时重新处理记录，从而修正状

态。

Flink

用户还可以通过另一个特性有意识地管理状态版本，这个特性叫

作

保存点

（

savepoint

）。

60

｜

第

5

章

保存点与检查点的工作方式完全相同，只不过它由用户通过

Flink

命令行工

具或者

Web

控制台手动触发，而不由

Flink

自动触发。和检查点一样，保

存点也被保存在稳定存储中。用户可以从保存点重启作业，而不用从头开

始。保存点可以被视为作业在某一个特定时间点的快照（该时间点即为保

存点被触发的时间点）。

对保存点的另一种理解是，它在明确的时间点保存应用程序状态的版本。

这和用版本控制系统保存应用程序的版本很相似。最简单的例子是在不修

改应用程序代码的情况下，每隔固定的时间拍快照，即照原样保存应用程 ...