flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "zhijiang (Jira)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes
Date Mon, 28 Oct 2019 06:42:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

zhijiang updated FLINK-14230:
-----------------------------
    Description: 
This ticket is for fixing the error of propagating "endInput" on the chain immediately after
the input of the head operator is finished. Correctly, "endInput" of the downstream operator
should be invoked only after closing the upstream operator.

After "endInput" of the downstream operator on the chain is invoked correctly, we revert the
changes of PR#9298 and PR#9221.

>  Change the endInput call of the downstream operator to after the upstream operator closes
> ------------------------------------------------------------------------------------------
>
>                 Key: FLINK-14230
>                 URL: https://issues.apache.org/jira/browse/FLINK-14230
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Task
>            Reporter: Haibo Sun
>            Assignee: Haibo Sun
>            Priority: Major
>              Labels: pull-request-available
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> This ticket is for fixing the error of propagating "endInput" on the chain immediately
after the input of the head operator is finished. Correctly, "endInput" of the downstream
operator should be invoked only after closing the upstream operator.
> After "endInput" of the downstream operator on the chain is invoked correctly, we revert the
changes of PR#9298 and PR#9221.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message