flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [04/15] flink git commit: [FLINK-1266] Properly pass the fs.defaulFS setting when initializing filesystems
Date Sat, 10 Jan 2015 18:19:41 GMT
[FLINK-1266] Properly pass the fs.defaulFS setting when initializing filesystems


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

Branch: refs/heads/release-0.8
Commit: cd66ced4002418923d3459bfcf5a84a27f624910
Parents: 40a2705
Author: Robert Metzger <rmetzger@apache.org>
Authored: Thu Jan 8 12:28:06 2015 +0100
Committer: mbalassi <mbalassi@apache.org>
Committed: Thu Jan 8 13:50:26 2015 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/cd66ced4/flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
index 32e3f2d..8da7b82 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopFileSystem.java
@@ -263,8 +263,8 @@ public final class HadoopFileSystem extends FileSystem implements HadoopFileSyst
 	@Override
 	public void initialize(URI path) throws IOException {
 		
-		// For HDFS we have to have an authority
-		if (path.getAuthority() == null && path.getScheme().equals("hdfs")) {
+		// If the authority is not part of the path, we initialize with the fs.defaultFS entry.
+		if (path.getAuthority() == null) {
 			
 			String configEntry = this.conf.get("fs.defaultFS", null);
 			if (configEntry == null) {


Mime
View raw message