org.apache.hadoop.yarn.api.ApplicationClientProtocol.failApplicationAttempt()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(3.0k)|赞(0)|评价(0)|浏览(137)

本文整理了Java中org.apache.hadoop.yarn.api.ApplicationClientProtocol.failApplicationAttempt()方法的一些代码示例,展示了ApplicationClientProtocol.failApplicationAttempt()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ApplicationClientProtocol.failApplicationAttempt()方法的具体详情如下:
包路径:org.apache.hadoop.yarn.api.ApplicationClientProtocol
类名称:ApplicationClientProtocol
方法名:failApplicationAttempt

ApplicationClientProtocol.failApplicationAttempt介绍

[英]The interface used by clients to request the ResourceManager to fail an application attempt.

The client, via FailApplicationAttemptRequest provides the ApplicationAttemptId of the attempt to be failed.

In secure mode,the ResourceManager verifies access to the application, queue etc. before failing the attempt.

Currently, the ResourceManager returns an empty response on success and throws an exception on rejecting the request.
[中]客户端用于请求ResourceManager使应用程序尝试失败的接口。
客户端通过FailApplicationAtterRequest提供失败尝试的ApplicationAtterId。
在安全模式下,ResourceManager在尝试失败之前验证对应用程序、队列等的访问。
当前,ResourceManager在成功时返回空响应,在拒绝请求时抛出异常。

代码示例

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-router

@Override
public FailApplicationAttemptResponse failApplicationAttempt(
  FailApplicationAttemptRequest request) throws YarnException, IOException {
 return clientRMProxy.failApplicationAttempt(request);
}

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-client

@Override
public void failApplicationAttempt(ApplicationAttemptId attemptId)
  throws YarnException, IOException {
 LOG.info("Failing application attempt " + attemptId);
 FailApplicationAttemptRequest request =
   Records.newRecord(FailApplicationAttemptRequest.class);
 request.setApplicationAttemptId(attemptId);
 rmClient.failApplicationAttempt(request);
}

代码示例来源:origin: io.hops/hadoop-yarn-client

@Override
public void failApplicationAttempt(ApplicationAttemptId attemptId)
  throws YarnException, IOException {
 LOG.info("Failing application attempt " + attemptId);
 FailApplicationAttemptRequest request =
   Records.newRecord(FailApplicationAttemptRequest.class);
 request.setApplicationAttemptId(attemptId);
 rmClient.failApplicationAttempt(request);
}

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-common

@Override
public FailApplicationAttemptResponseProto failApplicationAttempt(RpcController arg0,
    FailApplicationAttemptRequestProto proto) throws ServiceException {
 FailApplicationAttemptRequestPBImpl request = new FailApplicationAttemptRequestPBImpl(proto);
 try {
  FailApplicationAttemptResponse response = real.failApplicationAttempt(request);
  return ((FailApplicationAttemptResponsePBImpl)response).getProto();
 } catch (YarnException e) {
  throw new ServiceException(e);
 } catch (IOException e) {
  throw new ServiceException(e);
 }
}

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public FailApplicationAttemptResponse failApplicationAttempt(
  ApplicationAttemptId attemptId) throws Exception {
 ApplicationClientProtocol client = getClientRMService();
 FailApplicationAttemptRequest req =
   FailApplicationAttemptRequest.newInstance(attemptId);
 FailApplicationAttemptResponse response =
   client.failApplicationAttempt(req);
 drainEventsImplicitly();
 return response;
}

相关文章

微信公众号

最新文章

更多

ApplicationClientProtocol类方法