[FLINK-14230] Change the endInput call of the downstream operator to after the upstream operator closes

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.10.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Haibo Sun
• Reporter: Haibo Sun
• Created: 26/Sep/19 11:56
• Updated: 28/Oct/19 06:44
• Resolved: 28/Oct/19 06:42

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.

Issue Links

• links to: GitHub Pull Request #9854