public class GridHadoopV1CombineTask extends GridHadoopTask {
public GridHadoopV1CombineTask(GridHadoopTaskInfo taskInfo) {
super(taskInfo);
}
@Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
<BUG>GridHadoopV1JobImpl jobImpl = (GridHadoopV1JobImpl)taskCtx.job();

JobContext jobCtx = jobImpl.hadoopJobContext();

Reducer combiner = U.newInstance(jobCtx.getJobConf().getCombinerClass());
combiner.configure(jobCtx.getJobConf());
GridHadoopTaskInput input = taskCtx.input();</BUG>
Reporter reporter = Reporter.NULL;

public class GridHadoopV1CombineTask extends GridHadoopTask {
public GridHadoopV1CombineTask(GridHadoopTaskInfo taskInfo) {
super(taskInfo);
}
@Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
GridHadoopV2JobImpl jobImpl = (GridHadoopV2JobImpl) taskCtx.job();
JobConf jobConf = jobImpl.hadoopJobContext().getJobConf();
Reducer combiner = U.newInstance(jobConf.getCombinerClass());
combiner.configure(jobConf);
GridHadoopTaskInput input = taskCtx.input();
Reporter reporter = Reporter.NULL;
