minor, fix UT
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/b6b0dc7c Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/b6b0dc7c Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/b6b0dc7c Branch: refs/heads/master Commit: b6b0dc7c846aa56aec9913931fcf7152067fd3c6 Parents: c341a62 Author: Roger Shi <rogershijich...@hotmail.com> Authored: Sat May 27 20:14:25 2017 +0800 Committer: æ <cheng.w...@kyligence.io> Committed: Sat May 27 20:20:06 2017 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/kylin/common/KylinConfigBase.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/b6b0dc7c/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 854ffbd..05be701 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 @@ -195,7 +195,7 @@ abstract public class KylinConfigBase implements Serializable { String root = getRequired("kylin.env.hdfs-working-dir"); Path path = new Path(root); - if (path.isAbsolute() == false) + if (!path.isAbsolute()) throw new IllegalArgumentException("kylin.env.hdfs-working-dir must be absolute, but got " + root); // make sure path is qualified @@ -209,10 +209,13 @@ abstract public class KylinConfigBase implements Serializable { // append metadata-url prefix root = new Path(path, StringUtils.replaceChars(getMetadataUrlPrefix(), ':', '-')).toString(); - if (root.endsWith("/") == false) + if (!root.endsWith("/")) root += "/"; cachedHdfsWorkingDirectory = root; + if (cachedHdfsWorkingDirectory.startsWith("file:")) { + cachedHdfsWorkingDirectory = cachedHdfsWorkingDirectory.replace("file:", "file://"); + } return cachedHdfsWorkingDirectory; }
