KYLIN-2833 Storage cleanup job could delete the intermediate hive table used by running jobs
Signed-off-by: Li Yang <liy...@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 <zhe...@outlook.com> Authored: Fri Sep 1 18:27:57 2017 +0800 Committer: Li Yang <liy...@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; }
