List of submitApplication() Examples

Examples of submitApplication()

com.cloudera.iterativereduce.yarn.ResourceManagerHandler.submitApplication()
org.apache.hadoop.yarn.api.ApplicationClientProtocol.submitApplication()

The interface used by clients to submit a new application to the ResourceManager.

The client is required to provide details such as queue, {@link Resource} required to run the ApplicationMaster, the equivalent of {@link ContainerLaunchContext} for launchingthe ApplicationMaster etc. via the {@link SubmitApplicationRequest}.

Currently the ResourceManager sends an immediate (empty) {@link SubmitApplicationResponse} on accepting the submission and throws an exception if it rejects the submission. However, this call needs to be followed by {@link #getApplicationReport(GetApplicationReportRequest)}to make sure that the application gets properly submitted.

In secure mode,the ResourceManager verifies access to queues etc. before accepting the application submission.
@param request request to submit a new application @return (empty) response on accepting the submission @throws YarnException @throws IOException @throws InvalidResourceRequestException The exception is thrown when a {@link ResourceRequest} is out ofthe range of the configured lower and upper resource boundaries. @see #getNewApplication(GetNewApplicationRequest)
org.apache.hadoop.yarn.api.ClientRMProtocol.submitApplication()

The interface used by clients to submit a new application to the ResourceManager.

The client is required to provide details such as queue, {@link Resource} required to run the ApplicationMaster, the equivalent of {@link ContainerLaunchContext} for launchingthe ApplicationMaster etc. via the {@link SubmitApplicationRequest}.

Currently the ResourceManager sends an immediate (empty) {@link SubmitApplicationResponse} on accepting the submission and throws an exception if it rejects the submission.

In secure mode,the ResourceManager verifies access to queues etc. before accepting the application submission.
@param request request to submit a new application @return (empty) response on accepting the submission @throws YarnRemoteException @see #getNewApplication(GetNewApplicationRequest)
org.apache.hadoop.yarn.client.api.YarnClient.submitApplication()

Submit a new application to YARN. It is a blocking call, such that it will not return {@link ApplicationId} until the submittedapplication has been submitted and accepted by the ResourceManager.
@param appContext {@link ApplicationSubmissionContext} containing all the detailsneeded to submit a new application @return {@link ApplicationId} of the accepted application @throws YarnException @throws IOException @see #createApplication()
org.apache.hadoop.yarn.server.resourcemanager.ClientRMService.submitApplication()
org.apache.slider.core.launch.AppMasterLauncher.submitApplication()
org.fenixedu.academic.domain.candidacy.GenericApplication.submitApplication()
org.springframework.yarn.client.YarnClient.submitApplication()
Submits the application known to {@link YarnClient} instance. @return the {@link ApplicationId} for submitted application

Examples of org.apache.hadoop.yarn.server.resourcemanager.ClientRMService.submitApplication()

            false, // unmanaged AM
            true, // cancelTokens
            1, // max app attempts
            Resource.newInstance(1024, 1));
    ClientRMService rmService = rm1.getClientRMService();
    rmService.submitApplication(SubmitApplicationRequest.newInstance(asc));


    for (int i = 0; i < 30; i++) {
      if (HAServiceProtocol.HAServiceState.ACTIVE ==
          rm1.getRMContext().getRMAdminService().getServiceStatus().getState()) {
        Thread.sleep(100);

View Full Code Here

Examples of org.apache.slider.core.launch.AppMasterLauncher.submitApplication()

    // Ignore the response as either a valid response object is returned on success
    // or an exception thrown to denote some form of a failure
    


    // submit the application
    LaunchedApplication launchedApplication = amLauncher.submitApplication();
    return launchedApplication;
  }
  
  
  /**

View Full Code Here

Examples of org.apache.slider.core.launch.AppMasterLauncher.submitApplication()

    // Ignore the response as either a valid response object is returned on success
    // or an exception thrown to denote some form of a failure
    


    // submit the application
    LaunchedApplication launchedApplication = amLauncher.submitApplication();
    return launchedApplication;
  }
  
  
  /**

View Full Code Here

Examples of org.fenixedu.academic.domain.candidacy.GenericApplication.submitApplication()

        RenderUtils.invalidateViewState();
        final GenericApplication application = getDomainObject(request, "applicationExternalId");
        final String confirmationCode = (String) getFromRequest(request, "confirmationCode");
        if (application != null && confirmationCode != null && application.getConfirmationCode() != null
                && application.getConfirmationCode().equals(confirmationCode)) {
            application.submitApplication();
            request.setAttribute("applicationSaved", Boolean.TRUE);
        }
        return confirmEmail(mapping, form, request, response);
    }

View Full Code Here

Examples of org.springframework.yarn.client.YarnClient.submitApplication()


  private void doSubmitAndAssert() throws Exception {
    YarnClient client = (YarnClient) ctx.getBean("yarnClient");
    assertThat(client, notNullValue());


    ApplicationId applicationId = client.submitApplication();
    assertThat(applicationId, notNullValue());


    YarnApplicationState state = null;
    for (int i = 0; i<120; i++) {
      state = findState(client, applicationId);

View Full Code Here

Examples of org.springframework.yarn.client.YarnClient.submitApplication()

        SpringYarnProperties syp = context.getBean(SpringYarnProperties.class);
        String applicationdir = SpringYarnBootUtils.resolveApplicationdir(syp);
        if (client instanceof ApplicationYarnClient) {
          return ((ApplicationYarnClient)client).submitApplication(new ApplicationDescriptor(applicationdir));
        } else {
          return client.submitApplication(false);
        }
      }


    }, args);
  }

View Full Code Here

Examples of org.springframework.yarn.client.YarnClient.submitApplication()

      ConfigurableApplicationContext context = null;
      try {
        context = new ClassPathXmlApplicationContext("application-context.xml");
        System.out.println("Submitting kill-application example");
        YarnClient client = (YarnClient) context.getBean("yarnClient");
        ApplicationId applicationId = client.submitApplication();
        System.out.println("Submitted kill-application example");
        System.out.println("Waiting 30 seconds before aborting the application");
        Thread.sleep(30000);
        System.out.println("Asking resource manager to abort application with applicationid=" + applicationId);
        client.killApplication(applicationId);

View Full Code Here

Examples of org.springframework.yarn.client.YarnClient.submitApplication()

    YarnClient client = ctx.getBean(YarnClient.class);
    if (install) {
      client.installApplication();
    }
    if (submit) {
      client.submitApplication(false);
    }
  }


}

View Full Code Here

0 1 2 3

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.