Flink 的 state 是存储在哪里的?

Johngo学长 Flink 40

Apache Flink内部有四种state的存储实现,具体如下

  • 基于内存的HeapStateBackend -在debug模式使用,不建议在生产模式下应用;
  • 基于HDFS的FsStateBackend -分布式文件持久化,每次读写都产生网络IO,整体性能不佳;
  • 基于RocksDB的RocksDBStateBackend -本地文件+异步HDFS持久化;
  • 基于Niagara(Alibaba内部实现)NiagaraStateBackend -分布式持久化-在Alibaba生产环境应用;

回复

我来回复
  • 暂无回复内容

免费咨询
免费咨询
扫码关注
扫码关注
联系站长

站长Johngo!

大数据和算法重度研究者!

持续产出大数据、算法、LeetCode干货,以及业界好资源!

2022012703491714

微信来撩,免费咨询:xiaozhu_tec

分享本页
返回顶部