Repository: hadoop Updated Branches: refs/heads/branch-2.8 a2020024e -> 0acf2bca9
MAPREDUCE-6873. MR Job Submission Fails if MR framework application path not on defaultFS. Contributed by Erik Krogen. (cherry picked from commit de7efd2687ccb74608249abf4c83c84a9345ec0a) (cherry picked from commit 3f5dc51ec94af5a20a319dd9bc807fc9e4db4f6a) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/0acf2bca Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/0acf2bca Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/0acf2bca Branch: refs/heads/branch-2.8 Commit: 0acf2bca9c19bcf76526d2ff59886931cd4041dd Parents: a202002 Author: Zhe Zhang <[email protected]> Authored: Wed Mar 29 22:10:55 2017 -0700 Committer: Zhe Zhang <[email protected]> Committed: Wed Mar 29 22:19:50 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/mapreduce/JobSubmitter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/0acf2bca/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobSubmitter.java ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobSubmitter.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobSubmitter.java index ddd1cb4..6db055a 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobSubmitter.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobSubmitter.java @@ -450,7 +450,7 @@ class JobSubmitter { // resolve any symlinks in the URI path so using a "current" symlink // to point to a specific version shows the specific version // in the distributed cache configuration - FileSystem fs = FileSystem.get(conf); + FileSystem fs = FileSystem.get(uri, conf); Path frameworkPath = fs.makeQualified( new Path(uri.getScheme(), uri.getAuthority(), uri.getPath())); FileContext fc = FileContext.getFileContext(frameworkPath.toUri(), conf); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
