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

为什么需要改造 Flink 引擎使 Checkpoint 满足 self-的条件？

为什么需要改造 Flink 引擎使 Checkpoint 满足 self-contained & relocatable 的条件？

展开
收起
夹心789 2024-07-30 16:37:51 67 分享 版权

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

1 条回答
写回答
取消 提交回答
  • 呆呆宝

    需要改造 Flink 引擎使 Checkpoint 满足 self-contained & relocatable 的条件，是因为只有满足这个条件，Checkpoint 的副本才是可用的，才能确保 Checkpoint 复制到其他地方后能够成功恢复作业。
    image.png

    2024-07-30 19:42:57
    赞同 3 展开评论
问答分类：
流计算 实时计算 Flink版
问答标签：
实时计算 Flink版checkpoint 实时计算 Flink版self
问答地址：
开发者社区 > 大数据 > 问答
相关问答
Flink问题还是topic分配不均匀，理论上1000个消费线程，是目前不满足这个预期吧？
144
2
0
Flink CDC中除了hive有没有那些引擎支持查询hbase的啊？
188
3
0
在1.0时代，阿里的实时计算有哪些引擎并存？
92
1
0
为什么B站需要优化Flink任务的提交引擎？
63
1
0
为什么中移的实时计算平台引入了引擎多版本设计？
40
1
0
为什么需要改造 Flink 引擎的 metadata 解析过程？
96
2
0
为什么直接在 Flink 引擎中双写到两个 HDFS 集群不是一个好的选择？
83
1
0
MySQL在Flink CDC中是什么引擎？
95
1
0
在Flink CDC中sink的这3个参数，只要满足其中1个就会触发sink吗？
74
0
0
Flink相比其他引擎有什么特点
50
0
0