reducer.close();
}
finally {
writer.close(reporter);
}
<BUG>OutputCommitter commiter = jobCtx.getJobConf().getOutputCommitter();
commiter.commitTask(new TaskAttemptContextImpl(jobCtx.getJobConf(), attempt));
}</BUG>
catch (IOException e) {
throw new GridException(e);

reducer.close();
}
finally {
writer.close(reporter);
}
OutputCommitter commiter = jobConf.getOutputCommitter();
commiter.commitTask(new TaskAttemptContextImpl(jobConf, attempt));
}
catch (IOException e) {
throw new GridException(e);
