MAPREDUCE-6873. MR Job Submission Fails if MR framework application path not on defaultFS. Contributed by Erik Krogen.

This commit is contained in:
Zhe Zhang 2017-03-29 22:10:55 -07:00
parent ceab00ac62
commit de7efd2687

View File

@ -458,7 +458,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);