[BEAM-1096] flink streaming side output optimization using SplitStream

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Affects Version/s: 0.4.0
• Fix Version/s: 0.4.0
• Component/s: runner-flink
• Assignee: Alexey Diomin
• Reporter: Alexey Diomin
• Created: 06/Dec/16 19:15
• Updated: 24/Jul/20 20:54
• Resolved: 08/Dec/16 01:57

Description

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

Issue Links

• links to: GitHub Pull Request #1520