@Override
  public void close() throws Exception {
    committer.stopAsync().awaitTerminated(1, TimeUnit.MINUTES);
  }
@Test
  public void close() throws Exception {
    committer.close();
    verify(fakeCommitter).stopAsync();
    verify(fakeCommitter).awaitTerminated(1, TimeUnit.MINUTES);
  }