标签：状态 这个 Java 管理 Flink 键控 --- 内存 组件

然后我们再来看这个,状态后端,这个是个可插入的组件,他主要是用来管理状态的,比如,对状态的维护,还需要有对状态的容错对吧,所以,首先为了保存状态,都是把状态保存到内存中的,但是为了

容错防止,机器down掉,会丢失状态还需要把状态在硬盘中存储一份.

这些复杂的状态管理,在分布式下如果我们自己实现就非常复杂,但是flink给我们提供了这个状态

管理组件,叫做state backend 状态后端.

可以看到,状态后端主要负责,本地状态管理,以及将检查点checkpoint状态写入远程存储起来.

然后我们再来看一下状态后端组件,都是有哪些.

1.首先看这个MemoryStateBackend,这个是内存级的状态后端组件,这个会将键控状态作为内存对象管理,把键控状态放到taskmanager的jvm堆上,将checkpoint,放到jobmanager的内存中,特点是快,

但是光放到内存中,安全性不好,一般生产环境都不用这个.如果机器坏了容易丢失状态.

2.然后FsStateBac

标签：状态,这个,Java,管理,Flink,键控,---,内存,组件
来源： https://blog.csdn.net/lidew521/article/details/123574663

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。