[FLINK-34371] FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Done
• Fix Version/s: 1.20.0
• Component/s: Runtime / Checkpointing, Runtime / Task
• Labels: pull-request-available

Release Note

For operators that only generates outputs after all inputs have been consumed, they are now optimized to run in blocking mode, and the other operators in the same job will wait to start until these operators have finished. Such operators include windowing with GlobalWindows#createWithEndOfStreamTrigger, sorting, and etc.

• Assignee: Yunfeng Zhou
• Reporter: Yunfeng Zhou
• Created: 06/Feb/24 02:52
• Updated: 08/Jul/24 12:14
• Resolved: 28/Feb/24 11:28

Description

This is an umbrella ticket for FLIP-331.

Issue Links

• links to: GitHub Pull Request #24272