Repository: tez Updated Branches: refs/heads/master de8b4600a -> eeb5fb31c
TEZ-3289. Tez Example MRRSleep job does not set Staging dir correctly on secure cluster. (Harish Jaiprakash via hitesh) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/eeb5fb31 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/eeb5fb31 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/eeb5fb31 Branch: refs/heads/master Commit: eeb5fb31c3777793aac431d210b9400818406893 Parents: de8b460 Author: Hitesh Shah <[email protected]> Authored: Fri Jun 3 16:23:56 2016 -0700 Committer: Hitesh Shah <[email protected]> Committed: Fri Jun 3 16:25:57 2016 -0700 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java | 1 + 2 files changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/eeb5fb31/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index f4a1d77..d90ebe4 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -7,6 +7,7 @@ INCOMPATIBLE CHANGES ALL CHANGES: + TEZ-3289. Tez Example MRRSleep job does not set Staging dir correctly on secure cluster. TEZ-3276. Tez Example MRRSleep job fails when tez.staging-dir fs is not same as default FS. TEZ-3280. LOG MRInputHelpers split generation message as INFO TEZ-909. Provide support for application tags http://git-wip-us.apache.org/repos/asf/tez/blob/eeb5fb31/tez-tests/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java ---------------------------------------------------------------------- diff --git a/tez-tests/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java b/tez-tests/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java index 716910d..b0bacf4 100644 --- a/tez-tests/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java +++ b/tez-tests/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java @@ -739,6 +739,7 @@ public class MRRSleepJob extends Configured implements Tool { String stagingBaseDir = conf.get(TezConfiguration.TEZ_AM_STAGING_DIR, TezConfiguration.TEZ_AM_STAGING_DIR_DEFAULT); Path stagingDir = new Path(stagingBaseDir, Long.toString(System.currentTimeMillis())); + stagingDir = stagingDir.getFileSystem(conf).makeQualified(stagingDir); TezClientUtils.ensureStagingDirExists(conf, stagingDir); DAG dag = createDAG(conf, stagingDir,
