Versions Compared

Key

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

...

  • JobModel generation phase: 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 for the samza job. 
  • ContainerAllocator phase: This happens after the JobModel generation phase and schedules each processor to run on a physical host by coordinating with the underlying ClusterManager and orchestrates the execution of the processor.

...