You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2017/04/03 08:26:04 UTC
ignite git commit: IGNITE-4813: Add MRJobConfig.TASK_ATTEMPT_ID value
to job config. This closes #1610.
Repository: ignite
Updated Branches:
refs/heads/master f726dc483 -> 32faeb944
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/master
Commit: 32faeb944402872b1f1e6e4e791ac9249e846b0f
Parents: f726dc4
Author: Ivan Veselovskiy <iv...@gridgain.com>
Authored: Mon Apr 3 11:25:48 2017 +0300
Committer: devozerov <vo...@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();