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/14 00:16:14 UTC
kylin git commit: KYLIN-3028 should use working-dir fs when not set
habase-fs
Repository: kylin
Updated Branches:
refs/heads/KYLIN-3028 [created] 2670ad611
KYLIN-3028 should use working-dir fs when not set habase-fs
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/2670ad61
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/2670ad61
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/2670ad61
Branch: refs/heads/KYLIN-3028
Commit: 2670ad611d7cefcb8fccb13a9a085bbba6cbb693
Parents: 3f3c42b
Author: shaofengshi <sh...@apache.org>
Authored: Tue Nov 14 08:16:08 2017 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Tue Nov 14 08:16:08 2017 +0800
----------------------------------------------------------------------
.../org/apache/kylin/storage/hbase/HBaseConnection.java | 11 +++++++++++
1 file changed, 11 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/2670ad61/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..960d0a3 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,17 @@ public class HBaseConnection {
String hbaseClusterFs = kylinConf.getHBaseClusterFs();
if (StringUtils.isNotEmpty(hbaseClusterFs)) {
conf.set(FileSystem.FS_DEFAULT_NAME_KEY, hbaseClusterFs);
+ } else {
+ FileSystem workingFS = null;
+ try {
+ workingFS = HadoopUtil.getWorkingFileSystem(conf);
+ } catch (IOException e) {
+ logger.error("failed to get working filesystem, skip it", e);
+ }
+
+ if (workingFS != null) {
+ conf.set(FileSystem.FS_DEFAULT_NAME_KEY, workingFS.toString());
+ }
}
// https://issues.apache.org/jira/browse/KYLIN-953