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