[ https://issues.apache.org/jira/browse/BEAM-1096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek updated BEAM-1096: ----------------------------------- Assignee: Alexey Diomin > flink streaming side output optimization using SplitStream > ---------------------------------------------------------- > > Key: BEAM-1096 > URL: https://issues.apache.org/jira/browse/BEAM-1096 > Project: Beam > Issue Type: Improvement > Components: runner-flink > Affects Versions: 0.4.0-incubating > Reporter: Alexey Diomin > Assignee: Alexey Diomin > Priority: Minor > Fix For: 0.4.0-incubating > > > Current implementation: > 1) send all events in all output streams > 2) filtering streams for necessary tags > Cons: increased cpu usage for serialization all events > Proposed implementation: > 1) route event in correct streams based on tag -- This message was sent by Atlassian JIRA (v6.3.4#6332)