@Override
  public OutputCommitter getOutputCommitter(TaskAttemptContext context) throws IOException {
    return new CopyCommitter(getOutputPath(context), context);
  }
@Test
  public void testGetOutputCommitter() {
    try {
      TaskAttemptContext context = new TaskAttemptContextImpl(new Configuration(),
        new TaskAttemptID("200707121733", 1, TaskType.MAP, 1, 1));
      context.getConfiguration().set("mapred.output.dir", "/out");
      Assert.assertTrue(new CopyOutputFormat().getOutputCommitter(context) instanceof CopyCommitter);
    } catch (IOException e) {
      LOG.error("Exception encountered ", e);
      Assert.fail("Unable to get output committer");
    }
  }