@Test
public void testFailOnNull() throws IOException {

  try {
    Pipe p = Pump.prime()
        .retain("line")
        .each(new Debug(true))
        .failOnNull("I should fail", "line")
        .toPipe();
    Tap tap = getSequenceFileTap(NULL_INPUT_PATH);
    CascadingHelper.get().getFlowConnector().connect(tap, Tests.getOutTap(), p).complete();
    fail("Expected an exception, but none was thrown");
  } catch (Exception e) {
    assertNotNull(e);
  }
}