[BEAM-4523] Implement Flink batch ExecutableStage context

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: Not applicable
• Component/s: runner-flink
• Assignee: Ben Sidhom
• Reporter: Ben Sidhom
• Created: 08/Jun/18 17:48
• Updated: 24/Jul/20 20:14
• Resolved: 21/Jun/18 21:11

Description

The the ExecutableStage context is a wrapper for the job and stage bundle factories and pooled artifact sources. It should take care of caching the overall job bundle factory since we do not have access to job lifecycle hooks in Flink but would like to reuse services and resources across operators within a given job.

FlinkExecutableStageContext already exists as a skeleton, but it needs to be fleshed out.

Issue Links

• is depended upon by: BEAM-2889 Flink runs portable pipelines
• links to: GitHub Pull Request #5588