org.apache.hadoop.tools.rumen.ZombieJob.getTaskAttemptInfo()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(1.8k)|赞(0)|评价(0)|浏览(91)

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

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);

相关文章