当前位置: 首页 > news >正文

flink状态不能跨算子

背景

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

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

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

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

http://www.lryc.cn/news/215729.html

相关文章:

  • 基于transformer的解码decode目标检测框架(修改DETR源码)
  • Java SE 学习笔记(十七)—— 单元测试、反射
  • HNU-计算机网络-实验1-应用协议与数据包分析实验(Wireshark)
  • 【深度学习】快速制作图像标签数据集以及训练
  • Spring Boot Web MVC
  • 设置防火墙
  • 3.Docker的客户端指令学习与实战
  • 【微服务开篇-RestTemplate服务调用、Eureka注册中心、Nacos注册中心】
  • python if和while的区别有哪些
  • Unity计时器
  • Unity热更新介绍
  • 在虚拟机centos7中部署docker+jenkins最新稳定版
  • nodejs express vue 点餐外卖系统源码
  • 微信小程序导入js使用时候报错
  • 相机存储卡被格式化了怎么恢复?数据恢复办法分享!
  • Firefox修改缓存目录的方法
  • maven子模块无法导入jar包问题
  • ardupilot开发 --- 代码解析 篇
  • C++引用概述
  • 精准努力,提升自己的核心竞争力——中国人民大学与加拿大女王大学金融硕士
  • string【C++】
  • 【Python爬虫】selenium4新版本使用指南
  • CCF_A 计算机视觉顶会CVPR2024投稿指南以及论文模板
  • 什么是鉴权?一篇文章带你了解postman的多种方式
  • go 语言介绍
  • 查询平均提速 700%,奇安信基于 Apache Doris 升级日志安全分析系统
  • Linux越学越头疼,我要怎么办?
  • 使用Fiddler进行Mock测试
  • js字符串支持多个分隔符分割
  • ajax-axios发送 get请求 或者 发送post请求带有请求体参数