@Override
  public void stop() {
    try {
      this.jobCoordinatorListener.ifPresent(JobCoordinatorListener::onJobModelExpired);
      if (this.jobPreparationComplete.get()) {
        this.currentDiagnosticsManager.ifPresent(StaticResourceJobCoordinator::quietlyStop);
        this.currentJobModelMonitors.ifPresent(JobModelMonitors::stop);
        this.coordinatorCommunication.stop();
      }
      this.startpointManager.ifPresent(StartpointManager::stop);
      this.systemAdmins.stop();
    } finally {
      this.jobCoordinatorListener.ifPresent(JobCoordinatorListener::onCoordinatorStop);
    }
  }
Keeps track of if the job coordinator has completed all preparation for running the job, including
publishing a new job model and starting the job model monitors.
samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinator.java