public long getContainerHeartbeatRetryCount() {
    return getLong(YARN_CONTAINER_HEARTBEAT_RETRY_COUNT, YARN_CONTAINER_HEARTBEAT_RETRY_COUNT_DEFAULT);
  }
Get coordinatorStreamFactory according to the configs
@return the name of coordinatorStreamFactory
samza-core/src/main/java/org/apache/samza/config/JobConfig.java