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/2de95a99 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/2de95a99 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/2de95a99 Branch: refs/heads/2.1.x Commit: 2de95a994a62f5b985818b577cb0239e74583602 Parents: b5c2928 Author: Roger Shi <rogershijich...@hotmail.com> Authored: Thu Aug 10 21:34:03 2017 +0800 Committer: Roger Shi <rogershijich...@hotmail.com> Committed: Sun Aug 13 22:38:48 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/2de95a99/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; }
