[FLINK-24644] Introduce broadcast output to support broadcast events to all the downstream operators

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: ml-2.0.0
• Component/s: Library / Machine Learning
• Labels: pull-request-available
• Assignee: Yun Gao
• Reporter: Yun Gao
• Created: 26/Oct/21 09:28
• Updated: 15/Dec/21 03:14
• Resolved: 27/Oct/21 15:53

Description

Iteration requires to broadcast the epoch-watermark inside iteration no matter what partitioner is used. Currently it is not directly supported by the DataStream API, thus we need use reflection to use some low-level operations to implement this functionality.

Issue Links

• links to: GitHub Pull Request #6