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 2015/10/15 09:46:41 UTC
incubator-kylin git commit: KYLIN-1068 add log in htable cleanup
Repository: incubator-kylin
Updated Branches:
refs/heads/KYLIN-1068 58dd59130 -> 34d090473
KYLIN-1068 add log in htable cleanup
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/34d09047
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/34d09047
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/34d09047
Branch: refs/heads/KYLIN-1068
Commit: 34d09047395cf463f2408bdd8ac7b82dbc4ad96d
Parents: 58dd591
Author: shaofengshi <sh...@apache.org>
Authored: Thu Oct 15 15:46:33 2015 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Thu Oct 15 15:46:33 2015 +0800
----------------------------------------------------------------------
.../org/apache/kylin/storage/hbase/util/StorageCleanupJob.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/34d09047/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/StorageCleanupJob.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/StorageCleanupJob.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/StorageCleanupJob.java
index 490c580..88cb7de 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/StorageCleanupJob.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/StorageCleanupJob.java
@@ -101,7 +101,7 @@ public class StorageCleanupJob extends AbstractHadoopJob {
}
}
- private void cleanUnusedHBaseTables(Configuration conf) throws MasterNotRunningException, ZooKeeperConnectionException, IOException {
+ private void cleanUnusedHBaseTables(Configuration conf) throws IOException {
CubeManager cubeMgr = CubeManager.getInstance(KylinConfig.getInstanceFromEnv());
IIManager iiManager = IIManager.getInstance(KylinConfig.getInstanceFromEnv());
@@ -117,6 +117,8 @@ public class StorageCleanupJob extends AbstractHadoopJob {
//only take care htables that belongs to self, and created more than 2 days
if (StringUtils.isEmpty(creationTime) || (System.currentTimeMillis() - Long.valueOf(creationTime) > TIME_THREADSHOLD)) {
allTablesNeedToBeDropped.add(desc.getTableName().getNameAsString());
+ } else {
+ logger.info("Exclude table " + desc.getTableName().getNameAsString() + " from drop list, as it is newly created");
}
}
}