import org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobAbortEvent; //导入依赖的package包/类
protected JobStateInternal checkJobAfterTaskCompletion(JobImpl job) {
  //check for Job failure
  if (job.failedMapTaskCount*100 > 
    job.allowedMapFailuresPercent*job.numMapTasks ||
    job.failedReduceTaskCount*100 > 
    job.allowedReduceFailuresPercent*job.numReduceTasks) {
    job.setFinishTime();

    String diagnosticMsg = "Job failed as tasks failed. " +
        "failedMaps:" + job.failedMapTaskCount + 
        " failedReduces:" + job.failedReduceTaskCount;
    LOG.info(diagnosticMsg);
    job.addDiagnostic(diagnosticMsg);
    job.eventHandler.handle(new CommitterJobAbortEvent(job.jobId,
        job.jobContext,
        org.apache.hadoop.mapreduce.JobStatus.State.FAILED));
    return JobStateInternal.FAIL_ABORT;
  }
  
  return job.checkReadyForCommit();
}
 

import org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobAbortEvent; //导入依赖的package包/类
@Override
public void transition(JobImpl job, JobEvent event) {
  job.metrics.endRunningJob(job);
  job.addDiagnostic("Job setup failed : "
      + ((JobSetupFailedEvent) event).getMessage());
  job.eventHandler.handle(new CommitterJobAbortEvent(job.jobId,
      job.jobContext,
      org.apache.hadoop.mapreduce.JobStatus.State.FAILED));
}
 

import org.apache.hadoop.mapreduce.v2.app.commit.CommitterJobAbortEvent; //导入依赖的package包/类
@Override
protected JobStateInternal checkJobAfterTaskCompletion(JobImpl job) {
  if (job.completedTaskCount == job.tasks.size()) {
    job.setFinishTime();
    job.eventHandler.handle(new CommitterJobAbortEvent(job.jobId,
        job.jobContext,
        org.apache.hadoop.mapreduce.JobStatus.State.KILLED));
    return JobStateInternal.KILL_ABORT;
  }
  //return the current state, Job not finished yet
  return job.getInternalState();
}