Java 类org.apache.hadoop.mapreduce.jobhistory.JobUnsuccessfulCompletionEvent 实例源码

项目：hadoop 文件：Job20LineHistoryEventEmitter.java

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

项目：aliyun-oss-hadoop-fs 文件：Job20LineHistoryEventEmitter.java

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

项目：big-c 文件：Job20LineHistoryEventEmitter.java

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

项目：hadoop-2.6.0-cdh5.4.3 文件：Job20LineHistoryEventEmitter.java

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

项目：hadoop-plus 文件：Job20LineHistoryEventEmitter.java

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

项目：hops 文件：Job20LineHistoryEventEmitter.java

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

项目：hadoop-TCP 文件：Job20LineHistoryEventEmitter.java

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

项目：hardfs 文件：Job20LineHistoryEventEmitter.java

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

项目：hadoop-on-lustre2 文件：Job20LineHistoryEventEmitter.java

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

项目：mapreduce-fork 文件：Job20LineHistoryEventEmitter.java

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

项目：hadoop 文件：JobImpl.java

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

项目：hadoop 文件：JobImpl.java

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

项目：hadoop 文件：JobImpl.java

@Override
public void transition(JobImpl job, JobEvent event) {
  //TODO Is this JH event required.
  job.setFinishTime();
  JobUnsuccessfulCompletionEvent failedEvent =
      new JobUnsuccessfulCompletionEvent(job.oldJobId,
          job.finishTime, 0, 0,
          jobHistoryString, job.diagnostics);
  job.eventHandler.handle(new JobHistoryEvent(job.jobId, failedEvent));
  job.finished(terminationState);
}

项目：hadoop 文件：TestMRAppMaster.java

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

项目：hadoop 文件：JobBuilder.java

private void processJobUnsuccessfulCompletionEvent(
    JobUnsuccessfulCompletionEvent event) {
  result.setOutcome(Pre21JobHistoryConstants.Values
      .valueOf(event.getStatus()));
  result.setFinishTime(event.getFinishTime());
  // No counters in JobUnsuccessfulCompletionEvent
}

项目：aliyun-oss-hadoop-fs 文件：JobImpl.java

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

项目：aliyun-oss-hadoop-fs 文件：JobImpl.java

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

项目：aliyun-oss-hadoop-fs 文件：JobImpl.java

@Override
public void transition(JobImpl job, JobEvent event) {
  //TODO Is this JH event required.
  job.setFinishTime();
  JobUnsuccessfulCompletionEvent failedEvent =
      new JobUnsuccessfulCompletionEvent(job.oldJobId,
          job.finishTime, 0, 0,
          jobHistoryString, job.diagnostics);
  job.eventHandler.handle(new JobHistoryEvent(job.jobId, failedEvent));
  job.finished(terminationState);
}

项目：aliyun-oss-hadoop-fs 文件：TestMRAppMaster.java

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

项目：aliyun-oss-hadoop-fs 文件：JobBuilder.java

private void processJobUnsuccessfulCompletionEvent(
    JobUnsuccessfulCompletionEvent event) {
  result.setOutcome(Pre21JobHistoryConstants.Values
      .valueOf(event.getStatus()));
  result.setFinishTime(event.getFinishTime());
  // No counters in JobUnsuccessfulCompletionEvent
}

项目：big-c 文件：JobImpl.java

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

项目：big-c 文件：JobImpl.java

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

项目：big-c 文件：JobImpl.java

@Override
public void transition(JobImpl job, JobEvent event) {
  //TODO Is this JH event required.
  job.setFinishTime();
  JobUnsuccessfulCompletionEvent failedEvent =
      new JobUnsuccessfulCompletionEvent(job.oldJobId,
          job.finishTime, 0, 0,
          jobHistoryString, job.diagnostics);
  job.eventHandler.handle(new JobHistoryEvent(job.jobId, failedEvent));
  job.finished(terminationState);
}

项目：big-c 文件：TestMRAppMaster.java

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

项目：big-c 文件：JobBuilder.java

private void processJobUnsuccessfulCompletionEvent(
    JobUnsuccessfulCompletionEvent event) {
  result.setOutcome(Pre21JobHistoryConstants.Values
      .valueOf(event.getStatus()));
  result.setFinishTime(event.getFinishTime());
  // No counters in JobUnsuccessfulCompletionEvent
}

项目：hadoop-2.6.0-cdh5.4.3 文件：JobImpl.java

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

项目：hadoop-2.6.0-cdh5.4.3 文件：JobImpl.java

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

项目：hadoop-2.6.0-cdh5.4.3 文件：JobImpl.java

@Override
public void transition(JobImpl job, JobEvent event) {
  //TODO Is this JH event required.
  job.setFinishTime();
  JobUnsuccessfulCompletionEvent failedEvent =
      new JobUnsuccessfulCompletionEvent(job.oldJobId,
          job.finishTime, 0, 0,
          jobHistoryString, job.diagnostics);
  job.eventHandler.handle(new JobHistoryEvent(job.jobId, failedEvent));
  job.finished(terminationState);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestMRAppMaster.java

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

项目：hadoop-2.6.0-cdh5.4.3 文件：JobBuilder.java

private void processJobUnsuccessfulCompletionEvent(
    JobUnsuccessfulCompletionEvent event) {
  result.setOutcome(Pre21JobHistoryConstants.Values
      .valueOf(event.getStatus()));
  result.setFinishTime(event.getFinishTime());
  // No counters in JobUnsuccessfulCompletionEvent
}

项目：hadoop-plus 文件：JobImpl.java

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

项目：hadoop-plus 文件：JobImpl.java

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

项目：hadoop-plus 文件：JobImpl.java

@Override
public void transition(JobImpl job, JobEvent event) {
  //TODO Is this JH event required.
  job.setFinishTime();
  JobUnsuccessfulCompletionEvent failedEvent =
      new JobUnsuccessfulCompletionEvent(job.oldJobId,
          job.finishTime, 0, 0,
          jobHistoryString);
  job.eventHandler.handle(new JobHistoryEvent(job.jobId, failedEvent));
  job.finished(terminationState);
}

项目：hadoop-plus 文件：JobBuilder.java

private void processJobUnsuccessfulCompletionEvent(
    JobUnsuccessfulCompletionEvent event) {
  result.setOutcome(Pre21JobHistoryConstants.Values
      .valueOf(event.getStatus()));
  result.setFinishTime(event.getFinishTime());
  // No counters in JobUnsuccessfulCompletionEvent
}

项目：FlexMap 文件：JobImpl.java

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

项目：FlexMap 文件：JobImpl.java

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

项目：FlexMap 文件：JobImpl.java

@Override
public void transition(JobImpl job, JobEvent event) {
  //TODO Is this JH event required.
  job.setFinishTime();
  JobUnsuccessfulCompletionEvent failedEvent =
      new JobUnsuccessfulCompletionEvent(job.oldJobId,
          job.finishTime, 0, 0,
          jobHistoryString, job.diagnostics);
  job.eventHandler.handle(new JobHistoryEvent(job.jobId, failedEvent));
  job.finished(terminationState);
}

项目：FlexMap 文件：TestMRAppMaster.java

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

项目：hops 文件：JobImpl.java

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

项目：hops 文件：JobImpl.java

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