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/10/24 15:58:27 UTC

[07/12] kylin git commit: KYLIN-2945 fix CI

KYLIN-2945 fix CI


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

Branch: refs/heads/2.2.x
Commit: 509952f13feea806483b4a60cfbe5d515ae9bdf5
Parents: 1a3a37a
Author: Li Yang <li...@apache.org>
Authored: Sun Oct 22 20:51:01 2017 +0800
Committer: Li Yang <li...@apache.org>
Committed: Sun Oct 22 20:51:01 2017 +0800

----------------------------------------------------------------------
 .../java/org/apache/kylin/storage/hdfs/HDFSResourceStore.java  | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/509952f1/storage-hbase/src/main/java/org/apache/kylin/storage/hdfs/HDFSResourceStore.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hdfs/HDFSResourceStore.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hdfs/HDFSResourceStore.java
index 720e7e2..14c080e 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hdfs/HDFSResourceStore.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hdfs/HDFSResourceStore.java
@@ -59,6 +59,12 @@ public class HDFSResourceStore extends ResourceStore {
         Preconditions.checkState(HDFS_SCHEME.equals(metadataUrl.getScheme()));
         
         String path = metadataUrl.getParameter("path");
+        if (path == null) {
+            // missing path is not expected, but don't fail it
+            path = kylinConfig.getHdfsWorkingDirectory() + "tmp_metadata";
+            logger.warn("Missing path, fall back to " + path);
+        }
+        
         fs = HadoopUtil.getFileSystem(path);
         Path metadataPath = new Path(path);
         if (fs.exists(metadataPath) == false) {