private ContainerProcessManager buildContainerProcessManager(ClusterManagerConfig clusterManagerConfig, SamzaApplicationState state,
      ClusterResourceManager clusterResourceManager, Optional<ContainerAllocator> allocator) {
    return buildContainerProcessManager(clusterManagerConfig, state, clusterResourceManager, allocator, false);
  }
Test AM requests a new container when a task fails
Error codes with same behavior - Disk failure, preemption and aborted
samza-core/src/test/java/org/apache/samza/clustermanager/TestContainerProcessManager.java