开发者社区> 问答> 正文

Flink中的 StateBackend 存储有几种呀?

Flink中的 StateBackend 存储有几种呀?

展开
收起
游客5ixw6pdymb5xs 2021-12-08 15:01:22 564 0
1 条回答
写回答
取消 提交回答
  • Flink在做计算的过程中经常需要存储中间状态,来避免数据丢失和状态恢复。选择的状态存储策略不同,会影响状态持久化如何和 checkpoint 交互。 Flink提供了三种状态存储方式:

    MemoryStateBackend,(同步 进行分布式快照) FsStateBackend,(可以使用,同步 进行分布式快照) RocksDBStateBackend,(异步 进行分布式快照) RocksDBStateBackend 除了第3种其他2种都是同步快照。也就是说用hdfs这种方式快照是会阻塞数据处理的,只有当两个barrier之间数据处理完成并完成快照之后才向下一个task发送数据并打入barrier n。我们不管异步快照,我们现在只说同步快照。

    2021-12-08 15:01:59
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载