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

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • None
    • None
    • 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

        Issue Links

          Activity

            People

              Unassigned Unassigned
              kw2542 Ke Wu
              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 - 2h
                  2h