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 2019/03/18 08:50:13 UTC

[kylin] branch master updated: KYLIN-3888 TableNotDisabledException when running "Convert Lookup Table to HFile"

This is an automated email from the ASF dual-hosted git repository.

shaofengshi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/master by this push:
     new 9c8d30b  KYLIN-3888 TableNotDisabledException when running "Convert Lookup Table to HFile"
9c8d30b is described below

commit 9c8d30b09b224dc173acd99ff4c62f51b2492e97
Author: Guangxu Cheng <gx...@apache.org>
AuthorDate: Mon Mar 18 15:35:21 2019 +0800

    KYLIN-3888 TableNotDisabledException when running "Convert Lookup Table to HFile"
---
 .../org/apache/kylin/storage/hbase/lookup/LookupTableToHFileJob.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/lookup/LookupTableToHFileJob.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/lookup/LookupTableToHFileJob.java
index 0b6e313..2a12575 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/lookup/LookupTableToHFileJob.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/lookup/LookupTableToHFileJob.java
@@ -165,9 +165,7 @@ public class LookupTableToHFileJob extends AbstractHadoopJob {
         extSnapshotInfoManager.removeSnapshot(tableName, lookupSnapshotID);
         String hTableName = snapshotInfo.getStorageLocationIdentifier();
         logger.info("remove related HBase table:{} for snapshot:{}", hTableName, lookupSnapshotID);
-        Connection conn = getHBaseConnection(kylinConfig);
-        Admin admin = conn.getAdmin();
-        admin.deleteTable(TableName.valueOf(hTableName));
+        HBaseConnection.deleteTable(kylinConfig.getStorageUrl(), hTableName);
     }
 
     private String[] getLookupKeyColumns(CubeInstance cube, String tableName) {