org.apache.hadoop.mapreduce.v2.api.records.TaskState#KILLED源码实例Demo

下面列出了org.apache.hadoop.mapreduce.v2.api.records.TaskState#KILLED 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： hadoop 文件： JobImpl.java

@Override
public JobStateInternal transition(JobImpl job, JobEvent event) {
  job.completedTaskCount++;
  LOG.info("Num completed Tasks: " + job.completedTaskCount);
  JobTaskEvent taskEvent = (JobTaskEvent) event;
  Task task = job.tasks.get(taskEvent.getTaskID());
  if (taskEvent.getState() == TaskState.SUCCEEDED) {
    taskSucceeded(job, task);
  } else if (taskEvent.getState() == TaskState.FAILED) {
    taskFailed(job, task);
  } else if (taskEvent.getState() == TaskState.KILLED) {
    taskKilled(job, task);
  }

  return checkJobAfterTaskCompletion(job);
}

源代码2 项目： big-c 文件： JobImpl.java

@Override
public JobStateInternal transition(JobImpl job, JobEvent event) {
  job.completedTaskCount++;
  LOG.info("Num completed Tasks: " + job.completedTaskCount);
  JobTaskEvent taskEvent = (JobTaskEvent) event;
  Task task = job.tasks.get(taskEvent.getTaskID());
  if (taskEvent.getState() == TaskState.SUCCEEDED) {
    taskSucceeded(job, task);
  } else if (taskEvent.getState() == TaskState.FAILED) {
    taskFailed(job, task);
  } else if (taskEvent.getState() == TaskState.KILLED) {
    taskKilled(job, task);
  }

  return checkJobAfterTaskCompletion(job);
}

源代码3 项目： hadoop 文件： TaskImpl.java

private static TaskState getExternalState(TaskStateInternal smState) {
  if (smState == TaskStateInternal.KILL_WAIT) {
    return TaskState.KILLED;
  } else {
    return TaskState.valueOf(smState.name());
  }
}

源代码4 项目： big-c 文件： TaskImpl.java

private static TaskState getExternalState(TaskStateInternal smState) {
  if (smState == TaskStateInternal.KILL_WAIT) {
    return TaskState.KILLED;
  } else {
    return TaskState.valueOf(smState.name());
  }
}

源代码5 项目： hadoop 文件： CompletedTask.java

@Override
public TaskState getState() {
  return taskInfo.getTaskStatus() == null ? TaskState.KILLED : TaskState
      .valueOf(taskInfo.getTaskStatus());
}

源代码6 项目： big-c 文件： CompletedTask.java

@Override
public TaskState getState() {
  return taskInfo.getTaskStatus() == null ? TaskState.KILLED : TaskState
      .valueOf(taskInfo.getTaskStatus());
}

方法所在类

org.apache.hadoop.mapreduce.v2.api.records.TaskState