Java 类org.apache.hadoop.mapreduce.v2.app.job.event.JobAbortCompletedEvent 实例源码

@SuppressWarnings("unchecked")
protected void handleJobAbort(CommitterJobAbortEvent event) {
  cancelJobCommit();

  try {
    committer.abortJob(event.getJobContext(), event.getFinalState());
  } catch (Exception e) {
    LOG.warn("Could not abort job", e);
  }

  context.getEventHandler().handle(new JobAbortCompletedEvent(
      event.getJobID(), event.getFinalState()));
}

@SuppressWarnings("unchecked")
protected void handleJobAbort(CommitterJobAbortEvent event) {
  cancelJobCommit();

  try {
    committer.abortJob(event.getJobContext(), event.getFinalState());
  } catch (Exception e) {
    LOG.warn("Could not abort job", e);
  }

  context.getEventHandler().handle(new JobAbortCompletedEvent(
      event.getJobID(), event.getFinalState()));
}

@SuppressWarnings("unchecked")
protected void handleJobAbort(CommitterJobAbortEvent event) {
  cancelJobCommit();

  try {
    committer.abortJob(event.getJobContext(), event.getFinalState());
  } catch (Exception e) {
    LOG.warn("Could not abort job", e);
  }

  context.getEventHandler().handle(new JobAbortCompletedEvent(
      event.getJobID(), event.getFinalState()));
}

@SuppressWarnings("unchecked")
protected void handleJobAbort(CommitterJobAbortEvent event) {
  cancelJobCommit();

  try {
    committer.abortJob(event.getJobContext(), event.getFinalState());
  } catch (Exception e) {
    LOG.warn("Could not abort job", e);
  }

  context.getEventHandler().handle(new JobAbortCompletedEvent(
      event.getJobID(), event.getFinalState()));
}

@SuppressWarnings("unchecked")
protected void handleJobAbort(CommitterJobAbortEvent event) {
  cancelJobCommit();

  try {
    committer.abortJob(event.getJobContext(), event.getFinalState());
  } catch (Exception e) {
    LOG.warn("Could not abort job", e);
  }

  context.getEventHandler().handle(new JobAbortCompletedEvent(
      event.getJobID(), event.getFinalState()));
}

@SuppressWarnings("unchecked")
protected void handleJobAbort(CommitterJobAbortEvent event) {
  cancelJobCommit();

  try {
    committer.abortJob(event.getJobContext(), event.getFinalState());
  } catch (Exception e) {
    LOG.warn("Could not abort job", e);
  }

  context.getEventHandler().handle(new JobAbortCompletedEvent(
      event.getJobID(), event.getFinalState()));
}

@SuppressWarnings("unchecked")
protected void handleJobAbort(CommitterJobAbortEvent event) {
  cancelJobCommit();

  try {
    committer.abortJob(event.getJobContext(), event.getFinalState());
  } catch (Exception e) {
    LOG.warn("Could not abort job", e);
  }

  context.getEventHandler().handle(new JobAbortCompletedEvent(
      event.getJobID(), event.getFinalState()));
}

@SuppressWarnings("unchecked")
protected void handleJobAbort(CommitterJobAbortEvent event) {
  cancelJobCommit();

  try {
    committer.abortJob(event.getJobContext(), event.getFinalState());
  } catch (Exception e) {
    LOG.warn("Could not abort job", e);
  }

  context.getEventHandler().handle(new JobAbortCompletedEvent(
      event.getJobID(), event.getFinalState()));
}

@SuppressWarnings("unchecked")
protected void handleJobAbort(CommitterJobAbortEvent event) {
  cancelJobCommit();

  try {
    committer.abortJob(event.getJobContext(), event.getFinalState());
  } catch (Exception e) {
    LOG.warn("Could not abort job", e);
  }

  context.getEventHandler().handle(new JobAbortCompletedEvent(
      event.getJobID(), event.getFinalState()));
}

@SuppressWarnings("unchecked")
protected void handleJobAbort(CommitterJobAbortEvent event) {
  cancelJobCommit();

  try {
    committer.abortJob(event.getJobContext(), event.getFinalState());
  } catch (Exception e) {
    LOG.warn("Could not abort job", e);
  }

  context.getEventHandler().handle(new JobAbortCompletedEvent(
      event.getJobID(), event.getFinalState()));
}

@Override
public void transition(JobImpl job, JobEvent event) {
  JobStateInternal finalState = JobStateInternal.valueOf(
      ((JobAbortCompletedEvent) event).getFinalState().name());
  job.unsuccessfulFinish(finalState);
}

@Override
public void transition(JobImpl job, JobEvent event) {
  JobStateInternal finalState = JobStateInternal.valueOf(
      ((JobAbortCompletedEvent) event).getFinalState().name());
  job.unsuccessfulFinish(finalState);
}

@Override
public void transition(JobImpl job, JobEvent event) {
  JobStateInternal finalState = JobStateInternal.valueOf(
      ((JobAbortCompletedEvent) event).getFinalState().name());
  job.unsuccessfulFinish(finalState);
}

@Override
public void transition(JobImpl job, JobEvent event) {
  JobStateInternal finalState = JobStateInternal.valueOf(
      ((JobAbortCompletedEvent) event).getFinalState().name());
  job.unsuccessfulFinish(finalState);
}

@Override
public void transition(JobImpl job, JobEvent event) {
  JobStateInternal finalState = JobStateInternal.valueOf(
      ((JobAbortCompletedEvent) event).getFinalState().name());
  job.unsuccessfulFinish(finalState);
}

@Override
public void transition(JobImpl job, JobEvent event) {
  JobStateInternal finalState = JobStateInternal.valueOf(
      ((JobAbortCompletedEvent) event).getFinalState().name());
  job.unsuccessfulFinish(finalState);
}

@Override
public void transition(JobImpl job, JobEvent event) {
  JobStateInternal finalState = JobStateInternal.valueOf(
      ((JobAbortCompletedEvent) event).getFinalState().name());
  job.unsuccessfulFinish(finalState);
}

@Override
public void transition(JobImpl job, JobEvent event) {
  JobStateInternal finalState = JobStateInternal.valueOf(
      ((JobAbortCompletedEvent) event).getFinalState().name());
  job.unsuccessfulFinish(finalState);
}

@Override
public void transition(JobImpl job, JobEvent event) {
  JobStateInternal finalState = JobStateInternal.valueOf(
      ((JobAbortCompletedEvent) event).getFinalState().name());
  job.unsuccessfulFinish(finalState);
}

@Override
public void transition(JobImpl job, JobEvent event) {
  JobStateInternal finalState = JobStateInternal.valueOf(
      ((JobAbortCompletedEvent) event).getFinalState().name());
  job.unsuccessfulFinish(finalState);
}