@Override
  public void onError(Throwable e) {
    LOG.error("Exception occurred in callbacks in the Cluster Resource Manager", e);
    exceptionOccurred = e;
  }
An error in the callback terminates the JobCoordinator
@param e the underlying exception/error
samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java