Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-4286

Pooled artifact source

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Minor
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: runner-flink
    • Labels:
      None

      Description

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                bsidhom Ben Sidhom
                Reporter:
                bsidhom Ben Sidhom
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 1.5h
                  1.5h