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

Question

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

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

Answer 1

使用Checkpointed本地用户实例状态的接口或通过RuntimeContext. 实际上，使用每个键状态更容易，因为您不需要实现任何检查点代码。

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