You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/10/20 16:51:33 UTC

[jira] [Closed] (FLINK-1160) Modify record readers to allow publishing events to specific inputs (instead of broadcast) in the union record reader

     [ https://issues.apache.org/jira/browse/FLINK-1160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gyula Fora closed FLINK-1160.
-----------------------------

> Modify record readers to allow publishing events to specific inputs (instead of broadcast) in the union record reader
> ---------------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-1160
>                 URL: https://issues.apache.org/jira/browse/FLINK-1160
>             Project: Flink
>          Issue Type: Improvement
>          Components: Distributed Runtime, Streaming
>            Reporter: Gyula Fora
>            Assignee: Gyula Fora
>            Priority: Minor
>
> In order to do efficient record acknowledgments for fault tolerance we need to modify record readers to allow publishing events to specific inputs in the union record reader. Currently only broadcasting is supported for all inputs which is unnecessary for the acknowledgements and poses significant network overhead.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)