[
https://issues.apache.org/jira/browse/BEAM-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17132226#comment-17132226
]
Beam JIRA Bot commented on BEAM-4286:
-------------------------------------
This issue is assigned but has not received an update in 30 days so it has been
labeled "stale-assigned". If you are still working on the issue, please give an
update and remove the label. If you are no longer working on the issue, please
unassign so someone else may work on it. In 7 days the issue will be
automatically unassigned.
> 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
> Priority: P3
> Labels: stale-assigned
> Time Spent: 1.5h
> Remaining Estimate: 0h
>
> 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
(v8.3.4#803005)
