You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "zhijiang (JIRA)" <ji...@apache.org> on 2019/08/19 00:40:00 UTC

[jira] [Created] (FLINK-13767) Migrate isFinished method from AvailabilityListener to AsyncDataInput

zhijiang created FLINK-13767:
--------------------------------

             Summary: Migrate isFinished method from AvailabilityListener to AsyncDataInput
                 Key: FLINK-13767
                 URL: https://issues.apache.org/jira/browse/FLINK-13767
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Network, Runtime / Task
            Reporter: zhijiang
            Assignee: zhijiang


AvailabilityListener is both used in AsyncDataInput and StreamTaskInput. We already introduced InputStatus for StreamTaskInput#emitNext, and then InputStatus#END_OF_INPUT has the same semantic with AvailabilityListener#isFinished.

But for the case of AsyncDataInput which is mainly used by InputGate layer, the isFinished() method is still needed at the moment. So we migrate this method from AvailabilityListener to  AsyncDataInput, and refactor the StreamInputProcessor implementations by using InputStatus to judge finished state.



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)