Есть ли способ передать сообщение всем менеджерам задач

Question

Интересно, есть ли способ во флинке транслировать событие (или что-то в этом роде), если определенное событие считывается из источника во все диспетчеры задач?

Чтобы быть более конкретным, я агрегирую данные о состояниис состоянием карты и если некоторые события считываются из источника, я хочу, чтобы все диспетчеры задач выполняли определенное действие

Возможно ли это?

Answer 1

Как отметил Дэвид, использование широковещательного потока является правильным способом отправки данных во все (параллельные) подзадачи. Что касается только широковещательной передачи некоторых данных, посмотрите на боковые выходы как способ сделать специальную обработку для подмножества ваших данных. Таким образом, у вас может быть ProcessFunction, который проходит через все данные без изменений, и если входящее событие является тем, которое хочет быть передано, то вы также отправляете его как побочный вывод.

Answer 2

Да, это возможно. шаблон состояния широковещания предназначен именно для такого случая использования.