From 54527b575cd005dd0e4432b5357ba6abab911f91 Mon Sep 17 00:00:00 2001
From: zhengdong <zhengd@outlook.com>
Date: Fri, 1 Sep 2017 18:27:57 +0800
Subject: [PATCH] KYLIN-2833 Storage cleanup job could delete the intermediate
 hive table used by running jobs

---
 .../src/main/java/org/apache/kylin/rest/job/StorageCleanupJob.java  | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)
 mode change 100644 => 100755 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 9b7278892..b23a33261
--- 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
@@ -319,10 +319,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;
     }
-- 
2.14.1