zhijiang created FLINK-13762:
--------------------------------
Summary: Integrate the implementation of
ForwardingValveOutputHandler for StreamOne/TwoInputProcessor
Key: FLINK-13762
URL: https://issues.apache.org/jira/browse/FLINK-13762
Project: Flink
Issue Type: Sub-task
Components: Runtime / Task
Reporter: zhijiang
Assignee: zhijiang
Currently StreamOneInputProcessor and StreamTwoInputSelectableProcessor have
separate implementations of ForwardingValveOutputHandler. Especially for the
implementation in StreamTwoInputSelectableProcessor, it couples the internal
input index logic which would be a blocker for the following unification of
StreamTaskInput/Output.
We could realize a unified ForwardingValveOutputHandler for both
StreamOneInput/ TwoInputSelectableProcessor, and it does not consider different
inputs to always consume StreamStatus. Then we refactor the implementation of
StreamStatusMaintainer for judging the status of different inputs internally
before really emitting the StreamStatus.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
