diff -cNr kylin-kylin-1.3.0-a/job/src/main/java/org/apache/kylin/job/hadoop/cube/MetadataCleanupJob.java kylin-kylin-1.3.0-b/job/src/main/java/org/apache/kylin/job/hadoop/cube/MetadataCleanupJob.java
*** kylin-kylin-1.3.0-a/job/src/main/java/org/apache/kylin/job/hadoop/cube/MetadataCleanupJob.java	2016-03-09 14:49:54.000000000 +0800
--- kylin-kylin-1.3.0-b/job/src/main/java/org/apache/kylin/job/hadoop/cube/MetadataCleanupJob.java	2016-05-11 15:52:31.217069243 +0800
***************
*** 153,159 ****
          for (ExecutablePO executable : allExecutable) {
              long lastModified = executable.getLastModified();
              ExecutableOutputPO output = executableDao.getJobOutput(executable.getUuid());
!             if (System.currentTimeMillis() - lastModified > TIME_THREADSHOLD_FOR_JOB && (output.getStatus().equals(JobStatusEnum.FINISHED.toString()) || output.getStatus().equals(JobStatusEnum.DISCARDED.toString()))) {
                  toDeleteResource.add(ResourceStore.EXECUTE_PATH_ROOT + "/" + executable.getUuid());
                  toDeleteResource.add(ResourceStore.EXECUTE_OUTPUT_ROOT + "/" + executable.getUuid());
  
--- 153,159 ----
          for (ExecutablePO executable : allExecutable) {
              long lastModified = executable.getLastModified();
              ExecutableOutputPO output = executableDao.getJobOutput(executable.getUuid());
!             if (System.currentTimeMillis() - lastModified > TIME_THREADSHOLD_FOR_JOB && (ExecutableState.SUCCEED.toString().equals(output.getStatus()) || output.getStatus().equals(JobStatusEnum.FINISHED.toString()) || output.getStatus().equals(JobStatusEnum.DISCARDED.toString()))) {
                  toDeleteResource.add(ResourceStore.EXECUTE_PATH_ROOT + "/" + executable.getUuid());
                  toDeleteResource.add(ResourceStore.EXECUTE_OUTPUT_ROOT + "/" + executable.getUuid());