You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ss...@apache.org on 2013/05/22 01:13:30 UTC
git commit: TEZ-129. Set LocalDirs correctly for MapReduce tasks.
(sseth)
Updated Branches:
refs/heads/TEZ-1 1b0fc3573 -> 37d7a4cc3
TEZ-129. Set LocalDirs correctly for MapReduce tasks. (sseth)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/37d7a4cc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/37d7a4cc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/37d7a4cc
Branch: refs/heads/TEZ-1
Commit: 37d7a4cc3d65aa754c1ce59444731ec944a20381
Parents: 1b0fc35
Author: Siddharth Seth <ss...@apache.org>
Authored: Tue May 21 16:13:00 2013 -0700
Committer: Siddharth Seth <ss...@apache.org>
Committed: Tue May 21 16:13:21 2013 -0700
----------------------------------------------------------------------
.../apache/tez/mapreduce/task/MRRuntimeTask.java | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/37d7a4cc/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/MRRuntimeTask.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/MRRuntimeTask.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/MRRuntimeTask.java
index 3b51889..e5dfd66 100644
--- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/MRRuntimeTask.java
+++ b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/task/MRRuntimeTask.java
@@ -45,7 +45,6 @@ import org.apache.hadoop.security.Credentials;
import org.apache.hadoop.security.UserGroupInformation;
import org.apache.hadoop.security.token.Token;
import org.apache.hadoop.util.StringUtils;
-import org.apache.hadoop.yarn.api.ApplicationConstants.Environment;
import org.apache.tez.common.TezEngineTaskContext;
import org.apache.tez.common.TezJobConfig;
import org.apache.tez.common.TezTaskUmbilicalProtocol;
@@ -169,6 +168,7 @@ public class MRRuntimeTask extends RuntimeTask {
}
job.set(MRJobConfig.JOB_LOCAL_DIR, job.get(TezJobConfig.JOB_LOCAL_DIR));
+ job.set(MRConfig.LOCAL_DIR, job.get(TezJobConfig.LOCAL_DIRS));
// setup the child's attempt directories
// Do the task-type specific localization