@Test
public void testCommitterFactoryUnknown() throws Throwable {

  Configuration conf = new Configuration();
  // set the factory to an unknown class
  conf.set(COMMITTER_FACTORY_CLASS, "unknown");
  intercept(RuntimeException.class,
      () -> getCommitterFactory(HDFS_PATH, conf));
}