本文整理了Java中org.apache.hadoop.yarn.api.ApplicationClientProtocol.failApplicationAttempt()
方法的一些代码示例,展示了ApplicationClientProtocol.failApplicationAttempt()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ApplicationClientProtocol.failApplicationAttempt()
方法的具体详情如下:
包路径:org.apache.hadoop.yarn.api.ApplicationClientProtocol
类名称: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;
}
内容来源于网络,如有侵权,请联系作者删除!