zhijiang created FLINK-13766:
--------------------------------
Summary: 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
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)
