开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink事件流关联 广播流时 为了避免来的时候没有广播的维度数据 我需要现在本地预加载一份内存

flink事件流关联 广播流时 为了避免来的时候没有广播的维度数据 我需要现在本地预加载一份内存 那我是不是可以理解成 我只要维护这一份本地内存就可以了? 是不是可以不需要广播变量了?

展开
收起
爱喝咖啡嘿 2022-12-27 15:21:19 359 0
1 条回答
写回答
取消 提交回答
  • 你是不是首次启动flink任务纬度数据join不全?后续增量事件流都能join上,是的话事实流比广播数据先到了,办法是在open方法里先读一下全量的纬度数据,广播流实际上是一个mapstate,你建一个普通的mapstate接收open方法里的全量纬度数据,然后在processbroadcastelement方法里加到广播流里,同时清空普通的mapstate——此回答整理自钉群“【③群】Apache Flink China社区”

    2022-12-27 17:26:59
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Apache Flink 案例集(2022版) 立即下载
    内存取证与IaaS云平台恶意行 为的安全监控 立即下载
    云服务器ECS内存增强型实例re6全新发布 立即下载