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 <[email protected]> Authored: Tue May 21 16:13:00 2013 -0700 Committer: Siddharth Seth <[email protected]> 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
