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/06/05 05:23:24 UTC
[36/67] [abbrv] kylin git commit: minor, fix UT
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 <ro...@hotmail.com>
Authored: Sat May 27 20:14:25 2017 +0800
Committer: 成 <ch...@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;
}