Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-2405 Simplify Job Runner
  3. SAMZA-2458

Update ProcessJobFactory and ThreadJobFactory to load full job config

Agile BoardAttach filesAttach ScreenshotVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: None
    • Labels:
      None

      Description

      ProcessJobFactory and ThreadJobFactory are used only by JobRunner, which is only used by RemoteApplicationRunner.

      In RemoteApplicationRunner, we only get submission config as ClusterBasedJobCoordinator is responsible for fetching the full job config now. Similarly, ProcessJobFactory as well as ThreadJobFactory need to fetch full job config first too.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              kw2542 Ke Wu

              Dates

              • Created:
                Updated:
                Resolved:

              Time Tracking

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

                Issue deployment