[BEAM-1393] Update Flink Runner to Flink 1.2.0

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.6.0
• Component/s: runner-flink
• Assignee: Jingsong Lee
• Reporter: Aljoscha Krettek
• Created: 05/Feb/17 10:20
• Updated: 24/Jul/20 20:13
• Resolved: 16/Feb/17 11:27

Description

When we update to 1.2.0 we can use the new internal Timer API that is available to Flink operators: InternalTimerService and also use broadcast state to store side-input data.

Issue Links

• is depended upon by: BEAM-1394 Use Flink InternalTimerService for TimerInternals
• is depended upon by: BEAM-1445 Use Flink broadcast state to store side-input data
• is depended upon by: BEAM-1456 Make UnboundedSourceWrapper snapshot to rescalable operator state in Flink Runner
• links to: GitHub Pull Request #1960
• links to: GitHub Pull Request #2012