Use Executor and JobClient Flink APIs on FlinkRunner
Open
flink
improvement
P3
runners
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
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.
Imported from Jira [BEAM-9732](https://issues.apache.org/jira/browse/BEAM-9732). Original Jira may contain additional context.
Reported by: iemejia.
Contributor guide
Assessment
This issue has not been assessed yet.