@Test
public void testFailedConfig() throws IOException, RuntimeException,
    FlumeSpecException, InterruptedException {

  LogicalNode node = drive("fail(\"null\")", "null");
  // Check that state is failed.
  assertEquals(DriverState.ERROR, node.getDriver().getState());
}