IGNITE-4813: Add MRJobConfig.TASK_ATTEMPT_ID value to job config. This closes #1610.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/32faeb94 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/32faeb94 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/32faeb94 Branch: refs/heads/ignite-1192 Commit: 32faeb944402872b1f1e6e4e791ac9249e846b0f Parents: f726dc4 Author: Ivan Veselovskiy <iveselovs...@gridgain.com> Authored: Mon Apr 3 11:25:48 2017 +0300 Committer: devozerov <voze...@gridgain.com> Committed: Mon Apr 3 11:25:48 2017 +0300 ---------------------------------------------------------------------- .../internal/processors/hadoop/impl/v2/HadoopV2Context.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/32faeb94/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2Context.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2Context.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2Context.java index b8ecf3e..f4d624a 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2Context.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2Context.java @@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.hadoop.impl.v2; import org.apache.hadoop.fs.Path; import org.apache.hadoop.mapreduce.Counter; import org.apache.hadoop.mapreduce.InputSplit; +import org.apache.hadoop.mapreduce.MRJobConfig; import org.apache.hadoop.mapreduce.MapContext; import org.apache.hadoop.mapreduce.OutputCommitter; import org.apache.hadoop.mapreduce.RecordReader; @@ -31,7 +32,6 @@ import org.apache.hadoop.mapreduce.task.JobContextImpl; import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.processors.hadoop.HadoopFileBlock; import org.apache.ignite.hadoop.HadoopInputSplit; -import org.apache.ignite.internal.processors.hadoop.HadoopMapperAwareTaskOutput; import org.apache.ignite.internal.processors.hadoop.HadoopTaskCancelledException; import org.apache.ignite.internal.processors.hadoop.HadoopTaskContext; import org.apache.ignite.internal.processors.hadoop.HadoopTaskInput; @@ -80,8 +80,9 @@ public class HadoopV2Context extends JobContextImpl implements MapContext, Reduc taskAttemptID = ctx.attemptId(); - conf.set("mapreduce.job.id", taskAttemptID.getJobID().toString()); - conf.set("mapreduce.task.id", taskAttemptID.getTaskID().toString()); + conf.set(MRJobConfig.ID, taskAttemptID.getJobID().toString()); + conf.set(MRJobConfig.TASK_ID, taskAttemptID.getTaskID().toString()); + conf.set(MRJobConfig.TASK_ATTEMPT_ID, taskAttemptID.toString()); output = ctx.output(); input = ctx.input();