[ https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895937#comment-16895937 ]
Guowei Ma commented on FLINK-13491: ----------------------------------- Currently, Operatorchain calls all operator's "endInput" together. An alternative way likes {code:java} operator1.endInput() operator1.close() operator2.endInput operator2.close() {code} this could flush the buffer data in the operator. > AsyncWaitOperator doesn't handle endInput call properly > ------------------------------------------------------- > > Key: FLINK-13491 > URL: https://issues.apache.org/jira/browse/FLINK-13491 > Project: Flink > Issue Type: Bug > Components: API / DataStream > Affects Versions: 1.9.0 > Reporter: Piotr Nowojski > Priority: Blocker > Fix For: 1.9.0 > > > 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]? -- This message was sent by Atlassian JIRA (v7.6.14#76016)