Flink key state在从ck恢复的话,会自动会获取ck中的状态,那么operator state要是没有自己实现CheckpointedFunction ,从ck中恢复的话也会自动获取对应的状态值吗?
Flink key state在从ck恢复的话,也会自动获取对应的状态值吗?[阿里云实时计算 Flink版]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
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中恢复。
算子状态区别于键控状态不需要keyby,如果是自定义算子状态则需要CheckpointedFunction重写2个方法:如何把算子状态持久化到ck,如何初始化算子状态——该回答整理自钉群“【③群】Apache Flink China社区”