[BEAM-7799] Support Splittable DoFn in Flink Streaming Runner

• Type: Improvement
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-flink
• Assignee: Unassigned
• Reporter: Pablo Estrada
• Created: 22/Jul/19 23:46
• Updated: 04/Jun/22 12:35

Description

The portable Flink runner should be able to execute SDFs in Python Streaming, and keep track of things like the watermarks for event time, and synchronized processing time.