[ https://issues.apache.org/jira/browse/FLINK-13766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-13766: ----------------------------------- Labels: pull-request-available (was: ) > Refactor the implementation of StreamInputProcessor based on > StreamTaskInput#emitNext > ------------------------------------------------------------------------------------- > > Key: FLINK-13766 > URL: https://issues.apache.org/jira/browse/FLINK-13766 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Task > Reporter: zhijiang > Assignee: zhijiang > Priority: Minor > Labels: pull-request-available > > The current processing in task input processor is based on the way of > pollNext. In order to unify the processing way of new source operator, we > introduce the new StreamTaskInput#emitNext(Output) instead of current > pollNext. Then we need to adjust the existing implementations of > StreamOneInputProcessor/StreamTwoInputSelectableProcessor based on the new > emit way. > To do so, we could integrate all the task inputs from network/source in a > unified processing on runtime side. -- This message was sent by Atlassian JIRA (v7.6.14#76016)