@Test
public void testAbortJob() throws IOException {

  // Setup the sample directory.
  generateSampleFiles();
  committer.abortJob(mockTaskAttemptContext, State.KILLED);
  // Ensure files are deleted by cleanup.
  assertThat(!ghfs.exists(outputPath)).isTrue();
  assertThat(!ghfs.exists(outputSampleFilePath)).isTrue();
  verify(mockCommitter).abortJob(eq(mockTaskAttemptContext), eq(State.KILLED));
}