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

Switch SamzaTaskProxy to use LocalityManager

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 0.14.0
    • None
    • None

    Description

      TasksResource(/tasks/) in samza-rest is relying on JobModelManager.readJobModel to get jobmodel from (CoordinatorStream, jobConfig). This created binary dependencies of systemstreams defined in task.inputs of job config into samza-rest. Managing those dependencies is hard and unnecessary.

      This PR updates TasksResource to use LocalityManager to read task to container locality.
      In the future, this api will read jobmodel from SamzaMetadatasystem store.

      Attachments

        Issue Links

          Activity

            People

              spvenkat Shanthoosh Venkataraman
              spvenkat Shanthoosh Venkataraman
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: