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/05/14 23:30:00 UTC

[jira] [Created] (BEAM-4286) Pooled artifact source

Ben Sidhom created BEAM-4286:
--------------------------------

             Summary: Pooled artifact source
                 Key: BEAM-4286
                 URL: https://issues.apache.org/jira/browse/BEAM-4286
             Project: Beam
          Issue Type: Bug
          Components: runner-flink
            Reporter: Ben Sidhom
            Assignee: Ben Sidhom


Because DistributeCache lifetimes are tied to operator lifetimes in Flink, we need a way to wrap operator-scoped artifact sources. Artifacts are inherently job-scoped and should be the same throughout a job's lifetime. For this reason, it is safe to pool artifact sources and serve artifacts from an arbitrary pooled source as long as the underlying source is still in scope.

We need a pooled source in order to satisfy the bundle factory interfaces. Using the job-scoped and stage-scoped bundle factories allows us to cache and reuse different components that serve SDK harnesses. Because the distributed cache lifetimes are specific to Flink, the pooled artifact source should probably live in a runner-specific directory.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)