@Test(expected = RuntimeException.class)
public void newRecordWriter_newOutputStreamException() throws IOException {

  doThrow(IOException.class).when(outputStreamFactory).create(LOCATION);
  underTest.newRecordWriter(schema1);
}