Flink中的 StateBackend 存储有几种呀?
Flink中的 StateBackend 存储有几种呀?
展开
收起
1
条回答
写回答
写回答
-
Flink在做计算的过程中经常需要存储中间状态，来避免数据丢失和状态恢复。选择的状态存储策略不同，会影响状态持久化如何和 checkpoint 交互。 Flink提供了三种状态存储方式：
MemoryStateBackend，（同步 进行分布式快照） FsStateBackend，（可以使用，同步 进行分布式快照） RocksDBStateBackend，（异步 进行分布式快照） RocksDBStateBackend 除了第3种其他2种都是同步快照。也就是说用hdfs这种方式快照是会阻塞数据处理的，只有当两个barrier之间数据处理完成并完成快照之后才向下一个task发送数据并打入barrier n。我们不管异步快照，我们现在只说同步快照。
2021-12-08 15:01:59赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
