如何同时使用键值状态和检查点？

Question

据我了解，键值状态接口允许在我的流程失败后恢复状态，但在重新部署流程后无法恢复状态。

如果我想在重新部署后恢复状态，我应该实现Checkpointed接口并从/到Checkpointed接口的键值状态使用方法保存/恢复状态（+不要忘记在部署前创建保存点并使用创建的保存点运行新流程）。对吧？

Answer 1

使用本地用户实例状态的Checkpointed 接口或通过RuntimeContext 获得的每个键状态正确地检查和恢复状态。实际上，使用 per-key 状态更容易，因为您不需要实现任何检查点代码。

如果您想显式停止 Flink 作业并在稍后恢复检查点状态并恢复它，您可以使用 Savepoints 执行此操作。保存点使用与连续检查点相同的机制，允许您在发生故障时重新启动作业。