Versions Compared

Old Version 112

changes.mady.by.user Shanthoosh Venkataraman

Saved on

compared with

New Version 113

changes.mady.by.user Shanthoosh Venkataraman

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • ApplicationMaster(JobCoordinator) in yarn deployment model generates the Job model(optimal processor to task assignment) and persists the JobModel in coordinator stream(kafka topic) associated with the samza job. 
  • ContainerAllocator phase(which happens after the JobModel generation) schedules each processor to run on a physical host by coordinating with the underlying ClusterManager and orchestrates the execution of the processor.

...