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)
