[FLINK-19269] Make the PushingAsyncDataInput.DataOutput aware of endOfInput

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Won't Do
• Fix Version/s: 1.12.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 17/Sep/20 07:21
• Updated: 09/Oct/20 14:08
• Resolved: 09/Oct/20 07:33

Description

As suggested in the FLIP-140 we want to implement the sorting inside of org.apache.flink.streaming.runtime.io.PushingAsyncDataInput.DataOutput. To do that we need to be notified about the end of input.

We can do that by adding an endInput method. Moreover we could move the logic of notifying the Bounded(One/Multi)Input operators from OperatorChain to that new method.

Issue Links

• links to: GitHub Pull Request #13423