嗯，正解，谢谢！
在 2021-12-14 14:26:35，"yidan zhao" <[email protected]> 写道： >应该在open中做全量数据的初始化。然后broadcastState做增量的更新。 > >Caizhi Weng <[email protected]> 于2021年12月14日周二 09:50写道： > >> Hi！ >> >> 可以看一下 event time temporal join [1] 是否满足需求。 >> >> [1] >> >> https://nightlies.apache.org/flink/flink-docs-release-1.13/zh/docs/dev/table/sql/queries/joins/#event-time-temporal-join >> >> casel.chen <[email protected]> 于2021年12月12日周日 11:12写道： >> >> > 有一个场景是通过一张mysql的控制表来控制kafka流中的元素分流到不同下游sink，例如事实表的kafka和维表hbase等。 >> > >> 可我发现BroadcastConnectedStream处理顺序是随机的，有可能kafka数据来了（processElement方法）但还对应的MapState里面并没有该数据对应的控制规则（规则已经写到mysql控制表并被flink >> > >> cdc获取到控制流里面，只是还没有被processBroadcastElement方法处理到）。但我是想所有的维表数据都先建立好在MapState里面，不会出现找到对应key情况，请问这要怎么实现呢？ >>
