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)

Reply via email to