You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "zhijiang (JIRA)" <ji...@apache.org> on 2019/08/18 20:24:00 UTC
[jira] [Updated] (FLINK-13762) Integrate the implementation of
ForwardingValveOutputHandler for StreamOne/TwoInputProcessor
[ https://issues.apache.org/jira/browse/FLINK-13762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
zhijiang updated FLINK-13762:
-----------------------------
Description:
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.
was:
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.
> 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
> Priority: Minor
>
> 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)