本文整理了Java中org.apache.hadoop.tools.rumen.ZombieJob.getTaskAttemptInfo()
方法的一些代码示例,展示了ZombieJob.getTaskAttemptInfo()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZombieJob.getTaskAttemptInfo()
方法的具体详情如下:
包路径:org.apache.hadoop.tools.rumen.ZombieJob
类名称:ZombieJob
方法名:getTaskAttemptInfo
[英]Get a TaskAttemptInfo with a TaskAttemptID associated with taskType, taskNumber, and taskAttemptNumber. This function does not care about locality, and follows the following decision logic: 1. Make up a TaskAttemptInfo if the task attempt is missing in trace, 2. Make up a TaskAttemptInfo if the task attempt has a KILLED final status in trace, 3. Otherwise (final state is SUCCEEDED or FAILED), construct the TaskAttemptInfo from the trace.
[中]获取TaskAttemptInfo,其中TaskAttemptID与taskType、taskNumber和taskAttemptNumber关联。此函数不关心局部性,并遵循以下决策逻辑:1。如果任务尝试在跟踪中丢失,则生成TaskAttemptInfo,2。如果任务尝试在跟踪3中具有已终止的最终状态,则生成TaskAttemptInfo。否则(最终状态为Successed或FAILED),从跟踪中构造TaskAttemptInfo。
代码示例来源:origin: ch.cern.hadoop/hadoop-rumen
return getTaskAttemptInfo(loggedTask, loggedAttempt);
} else if (loggedAttempt.getResult() == Values.SUCCESS) {
int loggedLocality = getLocality(loggedTask, loggedAttempt);
if (locality == loggedLocality) {
return getTaskAttemptInfo(loggedTask, loggedAttempt);
} else {
代码示例来源:origin: com.github.jiayuhan-it/hadoop-rumen
return getTaskAttemptInfo(loggedTask, loggedAttempt);
} else if (loggedAttempt.getResult() == Values.SUCCESS) {
int loggedLocality = getLocality(loggedTask, loggedAttempt);
if (locality == loggedLocality) {
return getTaskAttemptInfo(loggedTask, loggedAttempt);
} else {
代码示例来源:origin: ch.cern.hadoop/hadoop-rumen
taskNumber, locality);
} else {
return getTaskAttemptInfo(loggedTask, loggedAttempt);
代码示例来源:origin: com.github.jiayuhan-it/hadoop-rumen
taskNumber, locality);
} else {
return getTaskAttemptInfo(loggedTask, loggedAttempt);
内容来源于网络,如有侵权,请联系作者删除!