Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-1168

Migrate yarn local runner to use StreamProcessor

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • 0.15.0
    • None
    • None

    Description

      Right now LocalContainerRunner is used in Yarn to run SamzaContainers on each node. This is not consistent with the real local runner which uses StreamProcessor to run locally. We should be able to wrap the simple coordination (get jobModel) inside a JobCoordinator and make this a StreamProcessor.

      Attachments

        Issue Links

          is a child of

          Improvement - An improvement or enhancement to an existing feature or task. SAMZA-1789 Refactor the application runtime classes so that we have a unified pattern to write and launch applications in high- and low-level APIs in YARN and standalone

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              xinyu Xinyu Liu
              xinyu Xinyu Liu
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: