@Test
public void testLocalJobRunnerRetryCount() throws InterruptedException {

  int retryAttempts = 3;
  JobStatus jobStatus = createTestJobStatus(
      "job_20130313155005308_0001", JobStatus.SUCCEEDED);
  JobConf jobConf = createTestJobConf(
      new Configuration(), retryAttempts, baseUrl + "fail");
  JobEndNotifier.localRunnerNotification(jobConf, jobStatus);
  // Validate params
  assertEquals(retryAttempts + 1, FailServlet.calledTimes);
}