[BEAM-9732] Use Executor and JobClient Flink APIs on FlinkRunner

• Type: Improvement
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-flink
• Assignee: Unassigned
• Reporter: Ismaël Mejía
• Created: 09/Apr/20 09:35
• Updated: 04/Jun/22 15:30

Description

Flink introduced recently new APIs to execute jobs FLIP-73 and control their execution FLIP-74. These APIs align nicely with Beam's PipelineResult and are the new standard on Flink starting with version 1.10.0 so it makes sense that we use them in the Flink runner.