开发者社区> 问答> 正文

Flink 中的 State Backends是什么?有什么作用?分成哪几类?说说他们各自的优缺点?

Flink 中的 State Backends是什么?有什么作用?分成哪几类?说说他们各自的优缺点?

展开
收起
茶什i 2019-11-21 10:47:26 1565 0
1 条回答
写回答
取消 提交回答
  • Flink流计算中可能有各种方式来保存状态:

    • 窗口操作
    • 使用了KV操作的函数
    • 继承了CheckpointedFunction的函数
    • 当开始做checkpointing的时候,状态会被持久化到checkpoints里来规避数据丢失和状态恢复。选择的状态存储策略不同,会导致状态持久化如何和checkpoints交互。
    • Flink内部提供了这些状态后端:
    • MemoryStateBackend
    • FsStateBackend
    • RocksDBStateBackend
    • 如果没有其他配置,系统将使用MemoryStateBackend。
    2019-11-21 10:47:38
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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