ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dma...@apache.org
Subject [03/50] [abbrv] ignite git commit: IGNITE-4813: Add MRJobConfig.TASK_ATTEMPT_ID value to job config. This closes #1610.
Date Tue, 11 Apr 2017 01:38:03 GMT
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 <iveselovskiy@gridgain.com>
Authored: Mon Apr 3 11:25:48 2017 +0300
Committer: devozerov <vozerov@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();


Mime
View raw message