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

JobContext jobCtx = jobImpl.hadoopJobContext();

Mapper mapper = U.newInstance(jobCtx.getJobConf().getMapperClass());
InputFormat inFormat = jobCtx.getJobConf().getInputFormat();
GridHadoopFileBlock block = info().fileBlock();</BUG>
InputSplit split = new FileSplit(new Path(block.file().toString()), block.start(), block.length(), block.hosts());

public class GridHadoopV1MapTask extends GridHadoopTask {
public GridHadoopV1MapTask(GridHadoopTaskInfo taskInfo) {
super(taskInfo);
}
@Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
GridHadoopV2JobImpl jobImpl = (GridHadoopV2JobImpl) taskCtx.job();
JobConf jobConf = jobImpl.hadoopJobContext().getJobConf();
Mapper mapper = U.newInstance(jobConf.getMapperClass());
InputFormat inFormat = jobConf.getInputFormat();
GridHadoopFileBlock block = info().fileBlock();
InputSplit split = new FileSplit(new Path(block.file().toString()), block.start(), block.length(), block.hosts());
