Repository: hadoop Updated Branches: refs/heads/branch-3.1 0196ffaa2 -> daa14bf06
MAPREDUCE-7125. JobResourceUploader creates LocalFileSystem when it's not necessary. (Peter Cseh via wangda) Change-Id: I1aa720ed03739f6f4abeec46f6068e2ab332987a (cherry picked from commit 230d90c5b9cc0d6e74bf16b1cf6685a163a24d48) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/daa14bf0 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/daa14bf0 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/daa14bf0 Branch: refs/heads/branch-3.1 Commit: daa14bf06a56cc03513c4039c6da902af4d8b9d7 Parents: 0196ffa Author: Wangda Tan <[email protected]> Authored: Mon Sep 24 13:30:02 2018 -0700 Committer: Wangda Tan <[email protected]> Committed: Mon Sep 24 13:53:51 2018 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/hadoop/mapreduce/JobResourceUploader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/daa14bf0/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobResourceUploader.java ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobResourceUploader.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobResourceUploader.java index 1dbecb6..e106a54 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobResourceUploader.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/JobResourceUploader.java @@ -855,8 +855,8 @@ class JobResourceUploader { throw new IllegalArgumentException(e); } Path path = new Path(pathURI); - FileSystem localFs = FileSystem.getLocal(conf); if (pathURI.getScheme() == null) { + FileSystem localFs = FileSystem.getLocal(conf); // default to the local file system // check if the file exists or not first localFs.getFileStatus(path); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
