|
@@ -855,8 +855,8 @@ class JobResourceUploader {
|
|
throw new IllegalArgumentException(e);
|
|
throw new IllegalArgumentException(e);
|
|
}
|
|
}
|
|
Path path = new Path(pathURI);
|
|
Path path = new Path(pathURI);
|
|
- FileSystem localFs = FileSystem.getLocal(conf);
|
|
|
|
if (pathURI.getScheme() == null) {
|
|
if (pathURI.getScheme() == null) {
|
|
|
|
+ FileSystem localFs = FileSystem.getLocal(conf);
|
|
// default to the local file system
|
|
// default to the local file system
|
|
// check if the file exists or not first
|
|
// check if the file exists or not first
|
|
localFs.getFileStatus(path);
|
|
localFs.getFileStatus(path);
|