有没有办法将消息广播到所有任务管理器中



我想知道如果特定事件从源读取到所有任务管理器中,flink 中是否有办法广播事件(或类似的东西(。

更具体地说,我正在使用映射状态聚合状态数据,如果从源中读取某些事件,我希望所有任务管理器都执行特定操作

可能吗?

是的,这是可能的。广播状态模式正是针对此类用例而设计的。

正如David所指出的,使用广播流是将数据发送到所有(并行(子任务的正确方法。至于仅广播某些数据,请查看侧输出,作为对数据子集进行特殊处理的一种方式。因此,您可以有一个未经修改地传递所有数据的ProcessFunction,如果传入事件是要广播的事件,那么您也可以将其作为侧输出发出。

最新更新