>我需要知道 Apache Flink 如何从检查点恢复其状态,因为在运行纯作业与从保存点恢复时,我看不到启动时间和在运算符中看到第一个事件之间的任何区别。
状态是否从检查点/保存点延迟加载?
键控状态接口旨在使这种区别透明。正如 Dawid 所提到的,状态在作业启动期间加载。请注意,加载状态的含义取决于正在使用的状态后端。
在运算符状态的情况下,CheckpointedFunction
接口具有此方法
public void initializeState(FunctionInitializationContext context)
上下文具有isRestored()
方法,可让您知道是否正在从故障中恢复。有关更多详细信息(包括示例(,请参阅有关托管操作员状态的文档。