[
https://issues.apache.org/jira/browse/FLINK-34371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunfeng Zhou updated FLINK-34371:
---------------------------------
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.
> FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream
> operator attribute to optimize task deployment
> --------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-34371
> URL: https://issues.apache.org/jira/browse/FLINK-34371
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Checkpointing, Runtime / Task
> Reporter: Yunfeng Zhou
> Assignee: Yunfeng Zhou
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.20.0
>
>
> This is an umbrella ticket for FLIP-331.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
