十堰今天刚刚发生新闻,网站移动端优化工具,wordpress换空间搬家,wordpress 全站ssl背景
在flink中进行状态的维护和管理应该是我们经常做的事情#xff0c;但是有些同学认为名称一样的状态在不同算子之间的状态是同一个#xff0c;事实是这样吗#xff1f;
flink状态在保存点中的存放示意图
事实上#xff0c;每个状态都归属于对应的算子#xff0c;也…背景
在flink中进行状态的维护和管理应该是我们经常做的事情但是有些同学认为名称一样的状态在不同算子之间的状态是同一个事实是这样吗
flink状态在保存点中的存放示意图
事实上每个状态都归属于对应的算子也就是只要算子不一样即使底下的状态名称相同他们也是完全不同的两个状态示意图如下所示
我们对flink进行状态管理时需要注意flink中没有所谓的跨算子共享的状态比如如果两个算子想要同一份配置的数据那么可以两个算子都维护一份自己的广播状态或者这份配置就是从DB获取这样才能保证两个算子拿到的都是同一份数据
