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 0135a2204..b1b6fa802 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 @@ -167,6 +167,8 @@ public class LookupTableToHFileJob extends AbstractHadoopJob { logger.info("remove related HBase table:{} for snapshot:{}", hTableName, lookupSnapshotID); Connection conn = getHBaseConnection(kylinConfig); Admin admin = conn.getAdmin(); + if(admin.isTableEnabled(TableName.valueOf(hTableName))) + admin.disableTable(TableName.valueOf(hTableName)); admin.deleteTable(TableName.valueOf(hTableName)); }