You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ka...@apache.org on 2017/09/04 13:44:58 UTC
[47/50] [abbrv] kylin git commit: KYLIN-2833 Storage cleanup job
could delete the intermediate hive table used by running jobs
KYLIN-2833 Storage cleanup job could delete the intermediate hive table used by running jobs
Signed-off-by: Li Yang <li...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/14058bda
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/14058bda
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/14058bda
Branch: refs/heads/2622-2764
Commit: 14058bda896f7670c333ca14f614e7cdab0ce62c
Parents: 1da269d
Author: zhengdong <zh...@outlook.com>
Authored: Fri Sep 1 18:27:57 2017 +0800
Committer: Li Yang <li...@apache.org>
Committed: Sun Sep 3 20:15:58 2017 +0800
----------------------------------------------------------------------
.../main/java/org/apache/kylin/rest/job/StorageCleanupJob.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/14058bda/server-base/src/main/java/org/apache/kylin/rest/job/StorageCleanupJob.java
----------------------------------------------------------------------
diff --git a/server-base/src/main/java/org/apache/kylin/rest/job/StorageCleanupJob.java b/server-base/src/main/java/org/apache/kylin/rest/job/StorageCleanupJob.java
old mode 100644
new mode 100755
index 8bb06b5..6d1d44c
--- a/server-base/src/main/java/org/apache/kylin/rest/job/StorageCleanupJob.java
+++ b/server-base/src/main/java/org/apache/kylin/rest/job/StorageCleanupJob.java
@@ -324,10 +324,8 @@ public class StorageCleanupJob extends AbstractApplication {
for (String jobId : workingJobList) {
String segmentId = getSegmentIdFromJobId(jobId);
- if (null == segmentId)
- continue;
-
- return segUuid.equals(segmentId);
+ if (segUuid.equals(segmentId))
+ return true;
}
return false;
}