import org.apache.hadoop.mapreduce.v2.app.job.event.JobSetupCompletedEvent; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected void handleJobSetup(CommitterJobSetupEvent event) {
  try {
    committer.setupJob(event.getJobContext());
    context.getEventHandler().handle(
        new JobSetupCompletedEvent(event.getJobID()));
  } catch (Exception e) {
    LOG.warn("Job setup failed", e);
    context.getEventHandler().handle(new JobSetupFailedEvent(
        event.getJobID(), StringUtils.stringifyException(e)));
  }
}
 

import org.apache.hadoop.mapreduce.v2.app.job.event.JobSetupCompletedEvent; //导入依赖的package包/类
@Test
public void testJobPriorityUpdate() throws Exception {
  Configuration conf = new Configuration();
  AsyncDispatcher dispatcher = new AsyncDispatcher();
  Priority submittedPriority = Priority.newInstance(5);

  AppContext mockContext = mock(AppContext.class);
  when(mockContext.hasSuccessfullyUnregistered()).thenReturn(false);
  JobImpl job = createStubbedJob(conf, dispatcher, 2, mockContext);

  JobId jobId = job.getID();
  job.handle(new JobEvent(jobId, JobEventType.JOB_INIT));
  assertJobState(job, JobStateInternal.INITED);
  job.handle(new JobStartEvent(jobId));
  assertJobState(job, JobStateInternal.SETUP);
  // Update priority of job to 5, and it will be updated
  job.setJobPriority(submittedPriority);
  Assert.assertEquals(submittedPriority, job.getReport().getJobPriority());

  job.handle(new JobSetupCompletedEvent(jobId));
  assertJobState(job, JobStateInternal.RUNNING);

  // Update priority of job to 8, and see whether its updated
  Priority updatedPriority = Priority.newInstance(8);
  job.setJobPriority(updatedPriority);
  assertJobState(job, JobStateInternal.RUNNING);
  Priority jobPriority = job.getReport().getJobPriority();
  Assert.assertNotNull(jobPriority);

  // Verify whether changed priority is same as what is set in Job.
  Assert.assertEquals(updatedPriority, jobPriority);
}