|
@@ -463,7 +463,7 @@ class JobSubmitter {
|
|
// 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);
|