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)
