You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/10/13 19:58:34 UTC

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

Gyula Fora created FLINK-1160:
---------------------------------

             Summary: 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)