/**

   * The maximum number of application attempts.

   * It's a global setting for all application masters.

   */

yarn.resourcemanager.am.max-attempts

/**

   * Set the number of max attempts of the application to be submitted. WARNING:

   * it should be no larger than the global number of max attempts in the Yarn

   * configuration.

   * @param maxAppAttempts the number of max attempts of the application

   * to be submitted.

   */

  @Public

  @Stable

  public abstract void setMaxAppAttempts(int maxAppAttempts);

boolean keepContainersAcrossAppAttempts = false;

switch (finalAttemptState) {

  case FINISHED:

  {

    appEvent = new RMAppFinishedAttemptEvent(applicationId,

        appAttempt.getDiagnostics());

  }

  break;

  case KILLED:

  {

    // don't leave the tracking URL pointing to a non-existent AM

    appAttempt.setTrackingUrlToRMAppPage();

    appAttempt.invalidateAMHostAndPort();

    appEvent =

        new RMAppFailedAttemptEvent(applicationId,

            RMAppEventType.ATTEMPT_KILLED,

            "Application killed by user.", false);

  }

  break;

  case FAILED:

  {

    // don't leave the tracking URL pointing to a non-existent AM

    appAttempt.setTrackingUrlToRMAppPage();

    appAttempt.invalidateAMHostAndPort();

    if (appAttempt.submissionContext

      .getKeepContainersAcrossApplicationAttempts()

        && !appAttempt.submissionContext.getUnmanagedAM()) {

      // See if we should retain containers for non-unmanaged applications

      if (!appAttempt.shouldCountTowardsMaxAttemptRetry()) {

        // Premption, hardware failures, NM resync doesn't count towards

        // app-failures and so we should retain containers.

        keepContainersAcrossAppAttempts = true;

      } else if (!appAttempt.maybeLastAttempt) {

        // Not preemption, hardware failures or NM resync.

        // Not last-attempt too - keep containers.

        keepContainersAcrossAppAttempts = true;

      }

    }

    appEvent =

        new RMAppFailedAttemptEvent(applicationId,

          RMAppEventType.ATTEMPT_FAILED, appAttempt.getDiagnostics(),

          keepContainersAcrossAppAttempts);

  }

}

private void createNewAttempt() {

    ApplicationAttemptId appAttemptId =

        ApplicationAttemptId.newInstance(applicationId, attempts.size() + );

    RMAppAttempt attempt =

        new RMAppAttemptImpl(appAttemptId, rmContext, scheduler, masterService,

          submissionContext, conf,

          // The newly created attempt maybe last attempt if (number of

          // previously failed attempts(which should not include Preempted,

          // hardware error and NM resync) + 1) equal to the max-attempt

          // limit.

          maxAppAttempts == (getNumFailedAppAttempts() + ), amReq);

    attempts.put(appAttemptId, attempt);

    currentAttempt = attempt;

  }

int globalMaxAppAttempts = conf.getInt(YarnConfiguration.RM_AM_MAX_ATTEMPTS,

        YarnConfiguration.DEFAULT_RM_AM_MAX_ATTEMPTS);

    int individualMaxAppAttempts = submissionContext.getMaxAppAttempts();

    if (individualMaxAppAttempts <=  ||

        individualMaxAppAttempts > globalMaxAppAttempts) {

      this.maxAppAttempts = globalMaxAppAttempts;

      LOG.warn("The specific max attempts: " + individualMaxAppAttempts

          + " for application: " + applicationId.getId()

          + " is invalid, because it is out of the range [1, "

          + globalMaxAppAttempts + "]. Use the global max attempts instead.");

    } else {

      this.maxAppAttempts = individualMaxAppAttempts;

    }