当前位置:首页 > 编程笔记 > 正文
已解决

flink状态不能跨算子

来自网友在路上 183883提问 提问时间:2023-11-03 01:08:29阅读次数: 83

最佳答案 问答题库838位专家为你答疑解惑

背景

在flink中进行状态的维护和管理应该是我们经常做的事情,但是有些同学认为名称一样的状态在不同算子之间的状态是同一个,事实是这样吗?

flink状态在保存点中的存放示意图

事实上,每个状态都归属于对应的算子,也就是只要算子不一样,即使底下的状态名称相同,他们也是完全不同的两个状态,示意图如下所示:
在这里插入图片描述

我们对flink进行状态管理时需要注意,flink中没有所谓的跨算子共享的状态,比如如果两个算子想要同一份配置的数据,那么可以两个算子都维护一份自己的广播状态,或者这份配置就是从DB获取,这样才能保证两个算子拿到的都是同一份数据

查看全文

99%的人还看了

猜你感兴趣

版权申明

本文"flink状态不能跨算子":http://eshow365.cn/6-30664-0.html 内容来自互联网,请自行判断内容的正确性。如有侵权请联系我们,立即删除!