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)
