You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/01/05 18:38:50 UTC

[09/19] flink git commit: [hotfix] [core] Avoid redundant File path conversion in LocalFileSystem.getFileStatus(Path)

[hotfix] [core] Avoid redundant File path conversion in LocalFileSystem.getFileStatus(Path)


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b82f59f6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b82f59f6
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b82f59f6

Branch: refs/heads/master
Commit: b82f59f64326e81cd8d1703c859d13485dff6958
Parents: bc588aa
Author: Stephan Ewen <se...@apache.org>
Authored: Wed Dec 6 15:10:22 2017 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Jan 5 19:38:06 2018 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/flink/core/fs/local/LocalFileSystem.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/b82f59f6/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java
index d16108b..b1eb786 100644
--- a/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java
+++ b/flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java
@@ -108,7 +108,7 @@ public class LocalFileSystem extends FileSystem {
 	public FileStatus getFileStatus(Path f) throws IOException {
 		final File path = pathToFile(f);
 		if (path.exists()) {
-			return new LocalFileStatus(pathToFile(f), this);
+			return new LocalFileStatus(path, this);
 		}
 		else {
 			throw new FileNotFoundException("File " + f + " does not exist or the user running "