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.api.ApplicationClientProtocol.submitApplication()

      ApplicationClientProtocol client;
      SubmitApplicationRequest req;
      @Override
      public SubmitApplicationResponse run() {
        try {
          return client.submitApplication(req);
        } catch (YarnException e) {
          e.printStackTrace();
        } catch (IOException e) {
          e.printStackTrace();
        }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.ClientRMProtocol.submitApplication()

    clc.setResource(capability);
    clc.setApplicationACLs(acls);
    sub.setAMContainerSpec(clc);
    req.setApplicationSubmissionContext(sub);


    client.submitApplication(req);
    // make sure app is immediately available after submit
    waitForState(appId, RMAppState.ACCEPTED);
    return getRMContext().getRMApps().get(appId);
  }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.ClientRMProtocol.submitApplication()

    capability.setMemory(masterMemory);
    clc.setResource(capability);
    sub.setAMContainerSpec(clc);
    req.setApplicationSubmissionContext(sub);


    client.submitApplication(req);
    // make sure app is immediately available after submit
    waitForState(appId, RMAppState.ACCEPTED);
    return getRMContext().getRMApps().get(appId);
  }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.ClientRMProtocol.submitApplication()

    clc.setResource(capability);
    clc.setApplicationACLs(acls);
    sub.setAMContainerSpec(clc);
    req.setApplicationSubmissionContext(sub);


    client.submitApplication(req);
    // make sure app is immediately available after submit
    waitForState(appId, RMAppState.ACCEPTED);
    return getRMContext().getRMApps().get(appId);
  }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.ClientRMProtocol.submitApplication()

      ClientRMProtocol client;
      SubmitApplicationRequest req;
      @Override
      public SubmitApplicationResponse run() {
        try {
          return client.submitApplication(req);
        } catch (YarnRemoteException e) {
          e.printStackTrace();
        }
        return null;
      }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.ClientRMProtocol.submitApplication()

    clc.setResource(capability);
    clc.setApplicationACLs(acls);
    sub.setAMContainerSpec(clc);
    req.setApplicationSubmissionContext(sub);


    client.submitApplication(req);
    // make sure app is immediately available after submit
    waitForState(appId, RMAppState.ACCEPTED);
    return getRMContext().getRMApps().get(appId);
  }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.ClientRMProtocol.submitApplication()

      ClientRMProtocol client;
      SubmitApplicationRequest req;
      @Override
      public SubmitApplicationResponse run() {
        try {
          return client.submitApplication(req);
        } catch (YarnRemoteException e) {
          e.printStackTrace();
        }
        return null;
      }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.ClientRMProtocol.submitApplication()

    clc.setResource(capability);
    clc.setApplicationACLs(acls);
    sub.setAMContainerSpec(clc);
    req.setApplicationSubmissionContext(sub);


    client.submitApplication(req);
    // make sure app is immediately available after submit
    waitForState(appId, RMAppState.ACCEPTED);
    return getRMContext().getRMApps().get(appId);
  }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.ClientRMProtocol.submitApplication()

    capability.setMemory(masterMemory);
    clc.setResource(capability);
    sub.setAMContainerSpec(clc);
    req.setApplicationSubmissionContext(sub);
    
    client.submitApplication(req);
    // make sure app is immediately available after submit
    waitForState(appId, RMAppState.ACCEPTED);
    return getRMContext().getRMApps().get(appId);
  }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.ClientRMProtocol.submitApplication()

    clc.setResource(capability);
    clc.setApplicationACLs(acls);
    sub.setAMContainerSpec(clc);
    req.setApplicationSubmissionContext(sub);


    client.submitApplication(req);
    // make sure app is immediately available after submit
    waitForState(appId, RMAppState.ACCEPTED);
    return getRMContext().getRMApps().get(appId);
  }

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.