@Test
public void testCreateCommitter() throws IOException {

  IndirectBigQueryOutputCommitter committer =
      (IndirectBigQueryOutputCommitter) outputFormat.createCommitter(mockTaskAttemptContext);
  assertThat(committer.getDelegate()).isEqualTo(mockOutputCommitter);
  verify(mockFileOutputFormat).getOutputCommitter(eq(mockTaskAttemptContext));
}