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

    • 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

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                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