@Test
public void testEventHandlerE2EFailedJobDirNotSet() throws InterruptedException, IOException {

  fs.mkdirs(jobDir);
  eventHandlerThread = new EventHandler(fs, eventQueue);
  eventHandlerThread.start();
  eventHandlerThread.stop(null, metadata); // jobDir == null
  eventHandlerThread.join();
  assertEquals(fs.listStatus(jobDir).length, 0);
  Utils.cleanupHDFSPath(fs.getConf(), jobDir);
}