  @Test
  public void testWarc() throws Exception {

    String warc = "warc/at.warc";
    File warcFile = new File(ClassLoader.getSystemClassLoader().getResource(warc).getPath());
    assertTrue(warc + " does not exist: " + warcFile.getAbsolutePath(), warcFile.exists());
    Path input = new Path(tempDir, warc);
    addContentToFS(input, Files.toString(warcFile, Charsets.UTF_8));

    String jobName = "testWarc";
    String[] args = new JobArgs().withJobName(jobName).withClassname(WarcIngestMapper.class.getName())
        .withCollection(DEFAULT_COLLECTION).withZkString(getBaseUrl())
        .withInput(input.toUri().toString()).getJobArgs();

    int val = ToolRunner.run(conf, new IngestJob(), args);
    assertEquals(0, val);
    verifyJob(jobName, 3, new String[]{"<urn:uuid:b328f1fe-b2ee-45c0-9139-908850810b52>",
        "<urn:uuid:6ee9accb-a284-47ef-8785-ed28aee2f79e>"}, "warc.WARC-Target-URI", "warc.WARC-Warcinfo-ID");
  }