Ben Sidhom created BEAM-4523:
--------------------------------
Summary: Implement Flink ExecutableStage context
Key: BEAM-4523
URL: https://issues.apache.org/jira/browse/BEAM-4523
Project: Beam
Issue Type: Bug
Components: runner-flink
Reporter: Ben Sidhom
Assignee: Ben Sidhom
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)