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)
This commit is contained in:
parent
a2020024e2
commit
0acf2bca9c
@ -450,7 +450,7 @@ private static void addMRFrameworkToDistributedCache(Configuration conf)
|
|||||||
// resolve any symlinks in the URI path so using a "current" symlink
|
// resolve any symlinks in the URI path so using a "current" symlink
|
||||||
// to point to a specific version shows the specific version
|
// to point to a specific version shows the specific version
|
||||||
// in the distributed cache configuration
|
// in the distributed cache configuration
|
||||||
FileSystem fs = FileSystem.get(conf);
|
FileSystem fs = FileSystem.get(uri, conf);
|
||||||
Path frameworkPath = fs.makeQualified(
|
Path frameworkPath = fs.makeQualified(
|
||||||
new Path(uri.getScheme(), uri.getAuthority(), uri.getPath()));
|
new Path(uri.getScheme(), uri.getAuthority(), uri.getPath()));
|
||||||
FileContext fc = FileContext.getFileContext(frameworkPath.toUri(), conf);
|
FileContext fc = FileContext.getFileContext(frameworkPath.toUri(), conf);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user