[ https://issues.apache.org/jira/browse/FLINK-13762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-13762: ----------------------------------- Labels: pull-request-available (was: ) > Implement a unified StatusWatermarkOutputHandler 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 > Priority: Minor > Labels: pull-request-available > > Currently StreamOneInputProcessor and StreamTwoInputSelectableProcessor have > separate implementations of ForwardingValueOutputHandler. 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 ForwardingValueOutputHandler 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)