Apache Flink 如何从检查点/保存点恢复状态



>我需要知道 Apache Flink 如何从检查点恢复其状态,因为在运行纯作业与从保存点恢复时,我看不到启动时间和在运算符中看到第一个事件之间的任何区别。

状态是否从检查点/保存点延迟加载?

键控状态接口旨在使这种区别透明。正如 Dawid 所提到的,状态在作业启动期间加载。请注意,加载状态的含义取决于正在使用的状态后端。

在运算符状态的情况下,CheckpointedFunction接口具有此方法

public void initializeState(FunctionInitializationContext context)

上下文具有isRestored()方法,可让您知道是否正在从故障中恢复。有关更多详细信息(包括示例(,请参阅有关托管操作员状态的文档。

最新更新