[jira] [Created] (FLINK-13762) Integrate the implementation of ForwardingValveOutputHandler for StreamOne/TwoInputProcessor

[Shang Yuanchun (Jira)]

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)