You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Ben Sidhom (JIRA)" <ji...@apache.org> on 2018/06/21 21:12:00 UTC

[jira] [Closed] (BEAM-4523) Implement Flink batch ExecutableStage context

     [ https://issues.apache.org/jira/browse/BEAM-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ben Sidhom closed BEAM-4523.
----------------------------
       Resolution: Fixed
    Fix Version/s: Not applicable

> 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
>             Fix For: Not applicable
>
>          Time Spent: 1.5h
>  Remaining Estimate: 0h
>
> 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)