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/10/23 09:17:13 UTC
[3/4] kylin git commit: KYLIN-2846 use configured hbase namespace in
StorageCleanJobHbaseUtil
KYLIN-2846 use configured hbase namespace in StorageCleanJobHbaseUtil
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/dbf59e5c
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/dbf59e5c
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/dbf59e5c
Branch: refs/heads/master
Commit: dbf59e5cd06ad7bb45f22d89478bba7f19618608
Parents: f3d3585
Author: zeng.yaowu <51...@qq.com>
Authored: Sat Oct 21 23:05:17 2017 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Mon Oct 23 17:16:27 2017 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/rest/job/StorageCleanJobHbaseUtil.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/dbf59e5c/server-base/src/main/java/org/apache/kylin/rest/job/StorageCleanJobHbaseUtil.java
----------------------------------------------------------------------
diff --git a/server-base/src/main/java/org/apache/kylin/rest/job/StorageCleanJobHbaseUtil.java b/server-base/src/main/java/org/apache/kylin/rest/job/StorageCleanJobHbaseUtil.java
index aceebb4..9933fb4 100644
--- a/server-base/src/main/java/org/apache/kylin/rest/job/StorageCleanJobHbaseUtil.java
+++ b/server-base/src/main/java/org/apache/kylin/rest/job/StorageCleanJobHbaseUtil.java
@@ -50,7 +50,9 @@ public class StorageCleanJobHbaseUtil {
CubeManager cubeMgr = CubeManager.getInstance(kylinConfig);
// get all kylin hbase tables
try (HBaseAdmin hbaseAdmin = new HBaseAdmin(conf)) {
- String tableNamePrefix = kylinConfig.getHBaseTableNamePrefix();
+ String namespace = kylinConfig.getHBaseStorageNameSpace();
+ String tableNamePrefix = (namespace.equals("default") || namespace.equals(""))
+ ? kylinConfig.getHBaseTableNamePrefix() : (namespace + ":" + kylinConfig.getHBaseTableNamePrefix());
HTableDescriptor[] tableDescriptors = hbaseAdmin.listTables(tableNamePrefix + ".*");
List<String> allTablesNeedToBeDropped = new ArrayList<String>();
for (HTableDescriptor desc : tableDescriptors) {