zhijiang updated FLINK-13767:
    Summary: Refactor StreamInputProcessor#processInput based on InputStatus  
(was: Migrate isFinished method from AvailabilityListener to AsyncDataInput)

> Refactor StreamInputProcessor#processInput based on InputStatus
> ---------------------------------------------------------------
>                 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
>            Priority: Minor
>              Labels: pull-request-available
>          Time Spent: 10m
>  Remaining Estimate: 0h
> AvailabilityListener is both used in AsyncDataInput and StreamTaskInput. We 
> already introduced InputStatus for PushBasedAsyncDataInput#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 the 
> finished state.

This message was sent by Atlassian Jira

Reply via email to