[
https://issues.apache.org/jira/browse/BEAM-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ben Sidhom updated BEAM-4523:
-----------------------------
Summary: Implement Flink batch ExecutableStage context (was: Implement
Flink ExecutableStage context)
> Implement Flink batch 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
> Priority: Major
>
> 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)
