AI 助理
备案控制台
开发者社区 问答 正文

FS StateBackend 到 RocksDB StateBackend 状态恢复问题

Hi 社区，        如果实时任务状态后端之前是 FS StateBackend ，然后任务停止后，换成 RocksDB StateBackend 做恢复，作业状态能恢复吗？*来自志愿者整理的flink

展开
收起
雪哥哥 2021-12-05 12:26:50 704 分享
分享
 版权
举报

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 小阿怪

    目前的 Flink 版本应该都是不支持的，也就是说换了 StateBackend 不能正常恢复。Flink 1.13 做了这个事情，具体参考：FLIP41 和 FLINK-20976

    https://cwiki.apache.org/confluence/display/FLINK/FLIP-41%3A+Unify+Binary+format+for+Keyed+State

    https://issues.apache.org/jira/browse/FLINK-2097*来自志愿者整理的flink

    2021-12-05 17:55:11 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
问答分类：
流计算 实时计算 Flink版
问答地址：
开发者社区 > 大数据 > 问答
相关问答
我的cdc任务从savepoint恢复的时候内存配置还是和之前一样，报了写入checkpoint失败
475
0
0
FS StateBackend 到 RocksDB StateBackend 状态恢复不了怎么办？
507
1
0
rocksdb作为statebackend时，TM节点挂掉了，为何任务不能恢复呢？
590
1
0
Flink中对于state不是很大，但是需要频繁checkpoint的任务，backendstate
629
1
0
关于flink CheckPoint 状态数据保存的问题
868
1
0
元数据的 checkpoint是什么？
372
1
0
flink CheckPoint 状态下，每次chk的数据保存在哪里了？
848
1
0
Flink 从checkpoint恢复时，部分状态没有正确恢复
855
0
0
Flink 增量 Checkpoint ，容错恢复后，随着时间的推移，之前的 Checkpoint
758
1
0
Flink 1.6 版本，RocksDBStateBackend ,增量 Checkpoint 目录
678
1
0