You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2024/07/08 12:15:00 UTC

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

     [ 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)