Repository: kylin Updated Branches: refs/heads/master 727920b4d -> 363f858b8
KYLIN-2785 Handle Maprfs schema working directory Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/5008866f Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/5008866f Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/5008866f Branch: refs/heads/master Commit: 5008866f41efd13ce5abaf8cc19c09919fe698dd Parents: 0153263 Author: Roger Shi <rogershijich...@hotmail.com> Authored: Thu Aug 10 21:34:03 2017 +0800 Committer: Roger Shi <rogershijich...@gmail.com> Committed: Sun Aug 13 22:39:54 2017 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/kylin/common/KylinConfigBase.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/5008866f/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java ---------------------------------------------------------------------- diff --git a/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java b/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java index 3a06571..78abf22 100644 --- a/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java +++ b/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java @@ -220,6 +220,8 @@ abstract public class KylinConfigBase implements Serializable { cachedHdfsWorkingDirectory = root; if (cachedHdfsWorkingDirectory.startsWith("file:")) { cachedHdfsWorkingDirectory = cachedHdfsWorkingDirectory.replace("file:", "file://"); + } else if (cachedHdfsWorkingDirectory.startsWith("maprfs:")) { + cachedHdfsWorkingDirectory = cachedHdfsWorkingDirectory.replace("maprfs:", "maprfs://"); } return cachedHdfsWorkingDirectory; }
