import org.apache.hadoop.mapreduce.jobhistory.TaskAttemptUnsuccessfulCompletion; //导入依赖的package包/类
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new EventHandler<JobHistoryEvent>() {
    @Override
    public void handle(JobHistoryEvent event) {
      if (event.getType() == org.apache.hadoop.mapreduce.jobhistory.EventType.MAP_ATTEMPT_FAILED) {
        TaskAttemptUnsuccessfulCompletion datum = (TaskAttemptUnsuccessfulCompletion) event
            .getHistoryEvent().getDatum();
        Assert.assertEquals("Diagnostic Information is not Correct",
            "Test Diagnostic Event", datum.get(8).toString());
      }
    }
  };
}
 

import org.apache.hadoop.mapreduce.jobhistory.TaskAttemptUnsuccessfulCompletion; //导入依赖的package包/类
private void processTaskAttemptUnsuccessfulCompletionEvent(
    TaskAttemptUnsuccessfulCompletionEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getTaskAttemptId().toString());

  if (attempt == null) {
    return;
  }

  attempt.setResult(getPre21Value(event.getTaskStatus()));
  attempt.setHostName(event.getHostname(), event.getRackName());
  ParsedHost pHost = 
    getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }

  attempt.setFinishTime(event.getFinishTime());
  org.apache.hadoop.mapreduce.jobhistory.JhCounters counters =
      ((TaskAttemptUnsuccessfulCompletion) event.getDatum()).counters;
  attempt.incorporateCounters(
      counters == null ? EMPTY_COUNTERS : counters);
  attempt.arraySetClockSplits(event.getClockSplits());
  attempt.arraySetCpuUsages(event.getCpuUsages());
  attempt.arraySetGpuUsages(event.getGpuUsages());
  attempt.arraySetVMemKbytes(event.getVMemKbytes());
  attempt.arraySetPhysMemKbytes(event.getPhysMemKbytes());
  TaskAttemptUnsuccessfulCompletion t =
      (TaskAttemptUnsuccessfulCompletion) (event.getDatum());
  attempt.putDiagnosticInfo(t.error.toString());
}
 

import org.apache.hadoop.mapreduce.jobhistory.TaskAttemptUnsuccessfulCompletion; //导入依赖的package包/类
private void processTaskAttemptUnsuccessfulCompletionEvent(
    TaskAttemptUnsuccessfulCompletionEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getTaskAttemptId().toString());

  if (attempt == null) {
    return;
  }

  attempt.setResult(getPre21Value(event.getTaskStatus()));
  attempt.setHostName(event.getHostname(), event.getRackName());
  ParsedHost pHost = 
    getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }

  attempt.setFinishTime(event.getFinishTime());
  org.apache.hadoop.mapreduce.jobhistory.JhCounters counters =
      ((TaskAttemptUnsuccessfulCompletion) event.getDatum()).counters;
  attempt.incorporateCounters(
      counters == null ? EMPTY_COUNTERS : counters);
  attempt.arraySetClockSplits(event.getClockSplits());
  attempt.arraySetCpuUsages(event.getCpuUsages());
  attempt.arraySetVMemKbytes(event.getVMemKbytes());
  attempt.arraySetPhysMemKbytes(event.getPhysMemKbytes());
  TaskAttemptUnsuccessfulCompletion t =
      (TaskAttemptUnsuccessfulCompletion) (event.getDatum());
  attempt.putDiagnosticInfo(t.error.toString());
}