List of registerApplicationMaster() Examples

Examples of registerApplicationMaster()

com.cloudera.iterativereduce.yarn.ResourceManagerHandler.registerApplicationMaster()
org.apache.hadoop.yarn.api.AMRMProtocol.registerApplicationMaster()

The interface used by a new ApplicationMaster to register with the ResourceManager.

The ApplicationMaster needs to provide details such as RPC Port, HTTP tracking url etc. as specified in {@link RegisterApplicationMasterRequest}.

The ResourceManager responds with critical details such as minimum and maximum resource capabilities in the cluster as specified in {@link RegisterApplicationMasterResponse}.
@param request registration request @return registration respose @throws YarnRemoteException
org.apache.hadoop.yarn.api.ApplicationMasterProtocol.registerApplicationMaster()

The interface used by a new ApplicationMaster to register with the ResourceManager.

The ApplicationMaster needs to provide details such as RPC Port, HTTP tracking url etc. as specified in {@link RegisterApplicationMasterRequest}.

The ResourceManager responds with critical details such as maximum resource capabilities in the cluster as specified in {@link RegisterApplicationMasterResponse}.
@param request registration request @return registration respose @throws YarnException @throws IOException @throws InvalidApplicationMasterRequestException The exception is thrown when an ApplicationMaster tries to register more then once. @see RegisterApplicationMasterRequest @see RegisterApplicationMasterResponse

Examples of com.cloudera.iterativereduce.yarn.ResourceManagerHandler.registerApplicationMaster()

    // Connect
    rmHandler.getAMResourceManager();
    
    // Register
    try {
      rmHandler.registerApplicationMaster(masterHost, masterPort);
    } catch (YarnRemoteException ex) {
      LOG.error(
          "Error encountered while trying to register application master", ex);
      return ReturnCode.MASTER_ERROR.getCode();
    }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.AMRMProtocol.registerApplicationMaster()

    // Register the appMaster
    RegisterApplicationMasterRequest request = recordFactory
        .newRecordInstance(RegisterApplicationMasterRequest.class);
    request.setApplicationAttemptId(resourceManager.getRMContext()
        .getRMApps().get(appID).getCurrentAppAttempt().getAppAttemptId());
    scheduler.registerApplicationMaster(request);
    return scheduler;
  }


  private Container requestAndGetContainer(AMRMProtocol scheduler,
      ApplicationId appID) throws YarnRemoteException, InterruptedException {

View Full Code Here

Examples of org.apache.hadoop.yarn.api.AMRMProtocol.registerApplicationMaster()

      AMRMProtocol rmClient = createRMClient(rm, conf, rpc, currentUser);


      RegisterApplicationMasterRequest request =
          Records.newRecord(RegisterApplicationMasterRequest.class);
      request.setApplicationAttemptId(applicationAttemptId);
      rmClient.registerApplicationMaster(request);


      FinishApplicationMasterRequest finishAMRequest =
          Records.newRecord(FinishApplicationMasterRequest.class);
      finishAMRequest.setAppAttemptId(applicationAttemptId);
      finishAMRequest

View Full Code Here

Examples of org.apache.hadoop.yarn.api.AMRMProtocol.registerApplicationMaster()

      AMRMProtocol rmClient = createRMClient(rm, conf, rpc, currentUser);


      RegisterApplicationMasterRequest request =
          Records.newRecord(RegisterApplicationMasterRequest.class);
      request.setApplicationAttemptId(applicationAttemptId);
      rmClient.registerApplicationMaster(request);


      // One allocate call.
      AllocateRequest allocateRequest =
          Records.newRecord(AllocateRequest.class);
      allocateRequest.setApplicationAttemptId(applicationAttemptId);

View Full Code Here

Examples of org.apache.hadoop.yarn.api.AMRMProtocol.registerApplicationMaster()


    RegisterApplicationMasterRequest request = Records
        .newRecord(RegisterApplicationMasterRequest.class);
    request.setApplicationAttemptId(applicationAttemptId);
    RegisterApplicationMasterResponse response =
        client.registerApplicationMaster(request);
    Assert.assertEquals("Register response has bad ACLs", "*",
        response.getApplicationACLs().get(ApplicationAccessType.VIEW_APP));


    rm.stop();
  }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.AMRMProtocol.registerApplicationMaster()

        .newRecord(RegisterApplicationMasterRequest.class);
    ApplicationAttemptId otherAppAttemptId = BuilderUtils
        .newApplicationAttemptId(applicationAttemptId.getApplicationId(), 42);
    request.setApplicationAttemptId(otherAppAttemptId);
    try {
      client.registerApplicationMaster(request);
      Assert.fail("Should fail with authorization error");
    } catch (YarnRemoteException e) {
      Assert.assertEquals("Unauthorized request from ApplicationMaster. "
          + "Expected ApplicationAttemptID: "
          + applicationAttemptId.toString() + " Found: "

View Full Code Here

Examples of org.apache.hadoop.yarn.api.AMRMProtocol.registerApplicationMaster()

    // Register the appMaster
    RegisterApplicationMasterRequest request = recordFactory
        .newRecordInstance(RegisterApplicationMasterRequest.class);
    request.setApplicationAttemptId(resourceManager.getRMContext()
        .getRMApps().get(appID).getCurrentAppAttempt().getAppAttemptId());
    scheduler.registerApplicationMaster(request);
    return scheduler;
  }


  private Container requestAndGetContainer(AMRMProtocol scheduler,
      ApplicationId appID) throws YarnRemoteException, InterruptedException {

View Full Code Here

Examples of org.apache.hadoop.yarn.api.AMRMProtocol.registerApplicationMaster()

    // Register the appMaster
    RegisterApplicationMasterRequest request = recordFactory
        .newRecordInstance(RegisterApplicationMasterRequest.class);
    request.setApplicationAttemptId(resourceManager.getRMContext()
        .getRMApps().get(appID).getCurrentAppAttempt().getAppAttemptId());
    scheduler.registerApplicationMaster(request);
    return scheduler;
  }


  private Container requestAndGetContainer(AMRMProtocol scheduler,
      ApplicationId appID) throws YarnRemoteException, InterruptedException {

View Full Code Here

Examples of org.apache.hadoop.yarn.api.AMRMProtocol.registerApplicationMaster()


    RegisterApplicationMasterRequest request = Records
        .newRecord(RegisterApplicationMasterRequest.class);
    request.setApplicationAttemptId(applicationAttemptId);
    RegisterApplicationMasterResponse response =
        client.registerApplicationMaster(request);
    Assert.assertEquals("Register response has bad ACLs", "*",
        response.getApplicationACLs().get(ApplicationAccessType.VIEW_APP));


    rm.stop();
  }

View Full Code Here

Examples of org.apache.hadoop.yarn.api.AMRMProtocol.registerApplicationMaster()

        .newRecord(RegisterApplicationMasterRequest.class);
    ApplicationAttemptId otherAppAttemptId = BuilderUtils
        .newApplicationAttemptId(applicationAttemptId.getApplicationId(), 42);
    request.setApplicationAttemptId(otherAppAttemptId);
    try {
      client.registerApplicationMaster(request);
      Assert.fail("Should fail with authorization error");
    } catch (YarnRemoteException e) {
      Assert.assertTrue(e.getMessage().contains(
          "Unauthorized request from ApplicationMaster. "
              + "Expected ApplicationAttemptID: "

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.