[FLINK-13491] AsyncWaitOperator doesn't handle endInput call properly

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.9.0
• Fix Version/s: 1.9.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Biao Liu
• Reporter: Piotr Nowojski
• Created: 30/Jul/19 08:20
• Updated: 01/Aug/19 10:17
• Resolved: 01/Aug/19 10:17

Description

This is the same issue as for ContinousFileReaderOperator in https://issues.apache.org/jira/browse/FLINK-13376. AsyncWaitOperator will propagate endInput notification immediately, even if it has some records buffered.

Side note, this also shows that the current BoundedOneInput#endInput API is easy to mishandle if an operator buffers some records internally. Maybe we could redesign this API somehow aljoscha sunhaibotb?

Issue Links

• relates to: FLINK-13486 AsyncDataStreamITCase.testOrderedWaitUsingAnonymousFunction instable on Travis
• links to: GitHub Pull Request #9298