import org.apache.hadoop.mapreduce.jobhistory.JobUnsuccessfulCompletionEvent; //导入依赖的package包/类
HistoryEvent maybeEmitEvent(ParsedLine line, String jobIDName,
    HistoryEventEmitter thatg) {
  if (jobIDName == null) {
    return null;
  }

  JobID jobID = JobID.forName(jobIDName);

  String finishTime = line.get("FINISH_TIME");

  String status = line.get("JOB_STATUS");

  String finishedMaps = line.get("FINISHED_MAPS");
  String finishedReduces = line.get("FINISHED_REDUCES");

  if (status != null && !status.equalsIgnoreCase("success")
      && finishTime != null && finishedMaps != null
      && finishedReduces != null) {
    return new JobUnsuccessfulCompletionEvent(jobID, Long
        .parseLong(finishTime), Integer.parseInt(finishedMaps), Integer
        .parseInt(finishedReduces), status);
  }

  return null;
}
 

import org.apache.hadoop.mapreduce.jobhistory.JobUnsuccessfulCompletionEvent; //导入依赖的package包/类
private void unsuccessfulFinish(JobStateInternal finalState) {
    if (finishTime == 0) setFinishTime();
    cleanupProgress = 1.0f;
    JobUnsuccessfulCompletionEvent unsuccessfulJobEvent =
        new JobUnsuccessfulCompletionEvent(oldJobId,
            finishTime,
            succeededMapTaskCount,
            succeededReduceTaskCount,
            finalState.toString(),
            diagnostics);
    eventHandler.handle(new JobHistoryEvent(jobId,
        unsuccessfulJobEvent));
    finished(finalState);
}
 

import org.apache.hadoop.mapreduce.jobhistory.JobUnsuccessfulCompletionEvent; //导入依赖的package包/类
@Override
public void transition(JobImpl job, JobEvent event) {
  job.setFinishTime();
  JobUnsuccessfulCompletionEvent failedEvent =
      new JobUnsuccessfulCompletionEvent(job.oldJobId,
          job.finishTime, 0, 0,
          JobStateInternal.KILLED.toString(), job.diagnostics);
  job.eventHandler.handle(new JobHistoryEvent(job.jobId, failedEvent));
  job.finished(JobStateInternal.KILLED);
}
 

import org.apache.hadoop.mapreduce.jobhistory.JobUnsuccessfulCompletionEvent; //导入依赖的package包/类
private void verifyFailedStatus(MRAppMasterTest appMaster,
    String expectedJobState) {
  ArgumentCaptor<JobHistoryEvent> captor = ArgumentCaptor
      .forClass(JobHistoryEvent.class);
  // handle two events: AMStartedEvent and JobUnsuccessfulCompletionEvent
  verify(appMaster.spyHistoryService, times(2))
      .handleEvent(captor.capture());
  HistoryEvent event = captor.getValue().getHistoryEvent();
  assertTrue(event instanceof JobUnsuccessfulCompletionEvent);
  assertEquals(((JobUnsuccessfulCompletionEvent) event).getStatus()
      , expectedJobState);
}
 

import org.apache.hadoop.mapreduce.jobhistory.JobUnsuccessfulCompletionEvent; //导入依赖的package包/类
private void processJobUnsuccessfulCompletionEvent(
    JobUnsuccessfulCompletionEvent event) {
  result.setOutcome(Pre21JobHistoryConstants.Values
      .valueOf(event.getStatus()));
  result.setFinishTime(event.getFinishTime());
  // No counters in JobUnsuccessfulCompletionEvent
}
 

import org.apache.hadoop.mapreduce.jobhistory.JobUnsuccessfulCompletionEvent; //导入依赖的package包/类
private void unsuccessfulFinish(JobStateInternal finalState) {
    if (finishTime == 0) setFinishTime();
    cleanupProgress = 1.0f;
    JobUnsuccessfulCompletionEvent unsuccessfulJobEvent =
        new JobUnsuccessfulCompletionEvent(oldJobId,
            finishTime,
            succeededMapTaskCount,
            succeededReduceTaskCount,
            finalState.toString());
    eventHandler.handle(new JobHistoryEvent(jobId,
        unsuccessfulJobEvent));
    finished(finalState);
}
 

import org.apache.hadoop.mapreduce.jobhistory.JobUnsuccessfulCompletionEvent; //导入依赖的package包/类
@Override
public void transition(JobImpl job, JobEvent event) {
  job.setFinishTime();
  JobUnsuccessfulCompletionEvent failedEvent =
      new JobUnsuccessfulCompletionEvent(job.oldJobId,
          job.finishTime, 0, 0,
          JobStateInternal.KILLED.toString());
  job.eventHandler.handle(new JobHistoryEvent(job.jobId, failedEvent));
  job.finished(JobStateInternal.KILLED);
}