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

  when(outputStreamFactory.create(LOCATION)).thenReturn(abortableOutputStream);
  doThrow(IOException.class).when(recordWriterFactory).create(eq(schema1), any(OutputStream.class));
  underTest.newRecordWriter(schema1);
}