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

Implement Flink batch ExecutableStage context

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: Not applicable
    • Component/s: runner-flink
    • Labels:
      None

      Description

      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.

        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:
                  Resolved:

                  Time Tracking

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