据我所知，键值状态接口允许在我的流失败后恢复状态，但不能在重新部署流后恢复状态。如果我想在重新部署后恢复状态，我应该实现 Checkpointed 接口和保存/还原状态从/到键值状态的使用方法 Checkpointed 接口（+在部署之前不要忘记创建保存点，并使用创建的保存点运行新流）。正确的？
Checkpointed
qf9go6mv1#
使用 Checkpointed 本地用户示例状态或通过 RuntimeContext . 实际上，使用每键状态更容易，因为您不需要实现任何检查点代码。如果要显式停止flink作业，并在稍后恢复检查点状态时恢复它，可以使用保存点来完成。保存点使用与连续检查点相同的机制，允许您在出现故障时重新启动作业。
RuntimeContext
1条答案
按热度按时间qf9go6mv1#
使用
Checkpointed本地用户示例状态或通过RuntimeContext. 实际上，使用每键状态更容易，因为您不需要实现任何检查点代码。如果要显式停止flink作业，并在稍后恢复检查点状态时恢复它，可以使用保存点来完成。保存点使用与连续检查点相同的机制，允许您在出现故障时重新启动作业。