public GridHadoopV1CleanupTask(GridHadoopTaskInfo taskInfo, boolean abort) {
super(taskInfo);
this.abort = abort;
}
@Override public void run(GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
<BUG>GridHadoopV1JobImpl jobImpl = (GridHadoopV1JobImpl)taskCtx.job();
</BUG>
JobContext jobCtx = jobImpl.hadoopJobContext();
try {
OutputCommitter commiter = jobCtx.getJobConf().getOutputCommitter();

public GridHadoopV1CleanupTask(GridHadoopTaskInfo taskInfo, boolean abort) {
super(taskInfo);
this.abort = abort;
}
@Override public void run(GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
GridHadoopV2JobImpl jobImpl = (GridHadoopV2JobImpl) taskCtx.job();
JobContext jobCtx = jobImpl.hadoopJobContext();
try {
OutputCommitter commiter = jobCtx.getJobConf().getOutputCommitter();
