首页 > 其他 > 详细

Flink的状态管理与恢复机制

时间:2020-02-08 22:51:06      阅读:184      评论:0      收藏:0      [点我收藏+]

问题一、什么是状态?

问题二、Flink状态类型有哪几种?

问题三、状态有什么作用?

问题四、如何使用状态,实现什么样的API?

问题五、什么是checkpoint与savepoint?
问题六、如何使用checkpoint与savepoint?
问题七、checkpoint原理是什么?

一、状态

定义:

某task/operator 在某一时刻的一个中间结果

快照(snapshot)

作用:

state可以被记录,在失败的情况下可以恢复。

基本类型:

Operator state

Keyed state

Flink提供一套状态保存的方法,无需在借助第三方存储系统来解决状态存储问题。

 

二、Flink状态类型有哪几种?

(1)Operator State

唯一绑定到特定operator

与key无关

提供的数据结构

ListState<T>

(2)Keyed State

基于KeyStream之上的状态,dataStream.keyBy()

KeyBy之后的Operator State

Organized by keyGroups

 

Flink的状态管理与恢复机制

原文:https://www.cnblogs.com/ssqq5200936/p/11026735.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!