Repository: hadoop Updated Branches: refs/heads/trunk 67173b484 -> 230d90c5b
MAPREDUCE-7125. JobResourceUploader creates LocalFileSystem when it's not necessary. (Peter Cseh via wangda) Change-Id: I1aa720ed03739f6f4abeec46f6068e2ab332987a Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/230d90c5 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/230d90c5 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/230d90c5 Branch: refs/heads/trunk Commit: 230d90c5b9cc0d6e74bf16b1cf6685a163a24d48 Parents: 67173b4 Author: Wangda Tan <[email protected]> Authored: Mon Sep 24 13:30:02 2018 -0700 Committer: Wangda Tan <[email protected]> Committed: Mon Sep 24 13:52:53 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/230d90c5/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]
