You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2014/05/27 20:57:40 UTC
git commit: TEZ-1027. orderedwordcount needs to respect
tez.staging-dir property. (Rekha Joshi via hitesh)
Repository: incubator-tez
Updated Branches:
refs/heads/master 763cb439b -> 0af037d68
TEZ-1027. orderedwordcount needs to respect tez.staging-dir property. (Rekha Joshi via hitesh)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/0af037d6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/0af037d6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/0af037d6
Branch: refs/heads/master
Commit: 0af037d68cbd20af225b7940c1d0a394776b580f
Parents: 763cb43
Author: Hitesh Shah <hi...@apache.org>
Authored: Tue May 27 11:54:39 2014 -0700
Committer: Hitesh Shah <hi...@apache.org>
Committed: Tue May 27 11:54:39 2014 -0700
----------------------------------------------------------------------
.../org/apache/tez/mapreduce/examples/OrderedWordCount.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/0af037d6/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
index 18a6327..e8139ac 100644
--- a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
+++ b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
@@ -348,9 +348,8 @@ public class OrderedWordCount extends Configured implements Tool {
FileSystem fs = FileSystem.get(conf);
- String stagingDirStr = Path.SEPARATOR + "user" + Path.SEPARATOR
- + user + Path.SEPARATOR+ ".staging" + Path.SEPARATOR
- + Path.SEPARATOR + appId.toString();
+ String stagingDirStr = conf.get(TezConfiguration.TEZ_AM_STAGING_DIR,
+ TezConfiguration.TEZ_AM_STAGING_DIR_DEFAULT) + Path.SEPARATOR + appId.toString();
Path stagingDir = new Path(stagingDirStr);
FileSystem pathFs = stagingDir.getFileSystem(tezConf);
pathFs.mkdirs(new Path(stagingDirStr));