You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2017/01/19 02:36:49 UTC

kylin git commit: KYLIN-2410 remove force qualified path in HadoopUtil.getFileSystem

Repository: kylin
Updated Branches:
  refs/heads/yang22 911a8a4db -> 5ef2480c0


KYLIN-2410 remove force qualified path in HadoopUtil.getFileSystem


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

Branch: refs/heads/yang22
Commit: 5ef2480c088649a76596f49ac2420d606152b4c3
Parents: 911a8a4
Author: Yang Li <li...@apache.org>
Authored: Thu Jan 19 10:35:50 2017 +0800
Committer: Yang Li <li...@apache.org>
Committed: Thu Jan 19 10:35:50 2017 +0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/kylin/common/util/HadoopUtil.java    | 3 ---
 1 file changed, 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/5ef2480c/core-common/src/main/java/org/apache/kylin/common/util/HadoopUtil.java
----------------------------------------------------------------------
diff --git a/core-common/src/main/java/org/apache/kylin/common/util/HadoopUtil.java b/core-common/src/main/java/org/apache/kylin/common/util/HadoopUtil.java
index a8477a9..de87d61 100644
--- a/core-common/src/main/java/org/apache/kylin/common/util/HadoopUtil.java
+++ b/core-common/src/main/java/org/apache/kylin/common/util/HadoopUtil.java
@@ -82,9 +82,6 @@ public class HadoopUtil {
     }
     
     public static FileSystem getFileSystem(Path path, Configuration conf) {
-        if (StringUtils.isBlank(path.toUri().getScheme()))
-            throw new IllegalArgumentException("Path must be qualified: " + path);
-        
         try {
             return path.getFileSystem(conf);
         } catch (IOException e) {