You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2017/11/22 06:00:32 UTC
[2/2] kylin git commit: KYLIN-3028 Build cube error when set S3 as
working-dir
KYLIN-3028 Build cube error when set S3 as working-dir
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/2b9470c3
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/2b9470c3
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/2b9470c3
Branch: refs/heads/master
Commit: 2b9470c38243c4678fb5d975664c82e7a9a87805
Parents: e4b1d7e
Author: shaofengshi <sh...@apache.org>
Authored: Wed Nov 22 13:56:06 2017 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Wed Nov 22 13:58:11 2017 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/storage/hbase/HBaseConnection.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/2b9470c3/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseConnection.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseConnection.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseConnection.java
index ef26334..16bd20d 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseConnection.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/HBaseConnection.java
@@ -154,6 +154,14 @@ public class HBaseConnection {
String hbaseClusterFs = kylinConf.getHBaseClusterFs();
if (StringUtils.isNotEmpty(hbaseClusterFs)) {
conf.set(FileSystem.FS_DEFAULT_NAME_KEY, hbaseClusterFs);
+ } else {
+ try {
+ FileSystem fs = HadoopUtil.getWorkingFileSystem(HadoopUtil.getCurrentConfiguration());
+ conf.set(FileSystem.FS_DEFAULT_NAME_KEY, fs.getUri().toString());
+ logger.debug("Using the working dir FS for HBase: " + fs.getUri().toString());
+ } catch (IOException e) {
+ logger.error("Fail to set working dir to HBase configuration", e);
+ }
}
// https://issues.apache.org/jira/browse/KYLIN-953