据我了解,键值状态接口允许在我的流程失败后恢复状态,但在重新部署流程后无法恢复状态。
如果我想在重新部署后恢复状态,我应该实现Checkpointed
接口并从/到键值状态使用Checkpointed
接口的方法保存/恢复状态(+不要忘记在部署之前创建保存点并使用创建的保存点运行新流程)。对?
据我了解,键值状态接口允许在我的流程失败后恢复状态,但在重新部署流程后无法恢复状态。
如果我想在重新部署后恢复状态,我应该实现Checkpointed
接口并从/到键值状态使用Checkpointed
接口的方法保存/恢复状态(+不要忘记在部署之前创建保存点并使用创建的保存点运行新流程)。对?
使用Checkpointed
本地用户实例状态的接口或通过RuntimeContext
. 实际上,使用每个键状态更容易,因为您不需要实现任何检查点代码。
如果您想显式停止 Flink 作业并在稍后恢复检查点状态并恢复它,您可以使用Savepoints来实现。保存点使用与连续检查点相同的机制,允许您在发生故障时重新启动作业。