我这边有个类似的实现，需要根据维表数据改变stream的处理，自定义了一个source（从MySQL中定时刷维表数据），kafka的stream union这个维表数据流， 额外增加一个数据类型（维表类型或者事实数据）进行数据的处理，后续算子将这个维表进行不同的处理并存到对应算子的state中。
发件人: Congxian Qiu <qcx978132...@gmail.com> 日期: 星期二, 2020年7月14日 14:03 收件人: user-zh <user-zh@flink.apache.org> 主题: Re: flink state Hi Robert Boardcast state[1] 是否满足你的需求呢？另外也可以看下这篇文章[2] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/stream/state/broadcast_state.html [2] https://cloud.tencent.com/developer/article/1509789 Best, Congxian Robert.Zhang <173603...@qq.com> 于2020年7月13日周一 下午9:50写道： > Hello,all > 目前stream中遇到一个问题， > 想使用一个全局的state 在所有的keyed stream中使用，或者global > parameter，主要的需求在于是这个state是可变的，需要对其进行修改并且对所有stream > operator可见，大家有遇到过类似场景或者可以提供相关思路么，感激不尽 > > > Best regards
