2

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

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

4

1 回答 1

2

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

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

于 2016-04-01T10:04:33.330 回答