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 2017/10/27 16:26:20 UTC
[3/8] flink git commit: [hotfix] [hdfs] Avoid reparsing URIs in
Hadoop File Status conversion
[hotfix] [hdfs] Avoid reparsing URIs in Hadoop File Status conversion
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f0964e1e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f0964e1e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f0964e1e
Branch: refs/heads/master
Commit: f0964e1e222835617607506f8e1d695278631a45
Parents: 7997715
Author: Stephan Ewen <se...@apache.org>
Authored: Tue Oct 24 19:46:07 2017 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Oct 27 17:37:22 2017 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/runtime/fs/hdfs/HadoopFileStatus.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/f0964e1e/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileStatus.java
----------------------------------------------------------------------
diff --git a/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileStatus.java b/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileStatus.java
index 17bb334..e1007b0 100644
--- a/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileStatus.java
+++ b/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileStatus.java
@@ -75,7 +75,7 @@ public final class HadoopFileStatus implements FileStatus {
@Override
public Path getPath() {
- return new Path(fileStatus.getPath().toString());
+ return new Path(fileStatus.getPath().toUri());
}
@SuppressWarnings("deprecation")