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 2016/06/24 07:04:50 UTC
[12/50] kylin git commit: minor, wording in StorageCleanup.job
minor, wording in StorageCleanup.job
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/5f2db8cc
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/5f2db8cc
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/5f2db8cc
Branch: refs/heads/stream_m1
Commit: 5f2db8cc1970f2945d9f4df5487b4ef162f958b9
Parents: 03f40dd
Author: shaofengshi <sh...@apache.org>
Authored: Fri Jun 17 16:33:24 2016 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Fri Jun 17 16:33:24 2016 +0800
----------------------------------------------------------------------
.../org/apache/kylin/storage/hbase/util/StorageCleanupJob.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/5f2db8cc/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 0bb8380..a5db52f 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
@@ -194,7 +194,7 @@ public class StorageCleanupJob extends AbstractHadoopJob {
if (!state.isFinalState()) {
String path = JobInstance.getJobWorkingDir(jobId, engineConfig.getHdfsWorkingDirectory());
allHdfsPathsNeedToBeDeleted.remove(path);
- logger.info("Remove " + path + " from deletion list, as the path belongs to job " + jobId + " with status " + state);
+ logger.info("Skip " + path + " from deletion list, as the path belongs to job " + jobId + " with status " + state);
}
}
@@ -205,7 +205,7 @@ public class StorageCleanupJob extends AbstractHadoopJob {
if (jobUuid != null && jobUuid.equals("") == false) {
String path = JobInstance.getJobWorkingDir(jobUuid, engineConfig.getHdfsWorkingDirectory());
allHdfsPathsNeedToBeDeleted.remove(path);
- logger.info("Remove " + path + " from deletion list, as the path belongs to segment " + seg + " of cube " + cube.getName());
+ logger.info("Skip " + path + " from deletion list, as the path belongs to segment " + seg + " of cube " + cube.getName());
}
}
}
@@ -257,7 +257,7 @@ public class StorageCleanupJob extends AbstractHadoopJob {
if (!state.isFinalState()) {
workingJobList.add(jobId);
- logger.info("Remove intermediate hive table with job id " + jobId + " with job status " + state);
+ logger.info("Skip intermediate hive table with job id " + jobId + " with job status " + state);
}
}