Flink key state在从ck恢复的话，也会自动获取对应的状态值吗？
Flink key state在从ck恢复的话，会自动会获取ck中的状态，那么operator state要是没有自己实现CheckpointedFunction ，从ck中恢复的话也会自动获取对应的状态值吗？
写回答
-
header-icon Flink在从Checkpoint恢复状态时，只会自动恢复实现了CheckpointedFunction接口的Operator State，而对于没有实现CheckpointedFunction接口的Keyed State和Broadcast State，则需要用户手动指定是否需要从Checkpoint中恢复。如果你没有实现CheckpointedFunction接口，那么在从Checkpoint中恢复状态时，Flink不会自动恢复你的Operator State。 对于Keyed State，是可以通过实现KeyedStateBackend接口的restore方法来手动从Checkpoint中恢复。
2023-03-19 10:03:38赞同 展开评论 打赏 -
算子状态区别于键控状态不需要keyby，如果是自定义算子状态则需要CheckpointedFunction重写2个方法：如何把算子状态持久化到ck，如何初始化算子状态——该回答整理自钉群“【③群】Apache Flink China社区”
2023-03-15 13:26:02赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关课程
更多
相关文章
相关电子书
更多
