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

Add Runner API pipeline and jobInfo in SamzaRunner configs

Details

    • Improvement
    • Status: Open
    • P2
    • Resolution: Unresolved
    • None
    • None
    • runner-samza

    Description

      Add 2 new fields

      • beamPipelinProto as the RunnerAPI pipeline 
      • beamJobInfo as the JobInfo

      They must be passed into the samza app in order to begin the samza container in portable mode

      Attachments

        Activity

          People

            dchen Daniel Chen
            dchen Daniel Chen
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: