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