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 <shaofeng...@apache.org> Authored: Fri Jun 17 16:33:24 2016 +0800 Committer: shaofengshi <shaofeng...@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); } }
