kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shaofeng...@apache.org
Subject kylin git commit: KYLIN-2070 remove check on building job
Date Thu, 20 Oct 2016 09:30:46 GMT
Repository: kylin
Updated Branches:
  refs/heads/master b9fdab7f8 -> 44f9ba566


KYLIN-2070 remove check on building job

Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/44f9ba56
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/44f9ba56
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/44f9ba56

Branch: refs/heads/master
Commit: 44f9ba56671e634916c6b7ba5759c1f09cbb9afc
Parents: b9fdab7
Author: shaofengshi <shaofengshi@apache.org>
Authored: Thu Oct 20 17:30:15 2016 +0800
Committer: shaofengshi <shaofengshi@apache.org>
Committed: Thu Oct 20 17:30:38 2016 +0800

----------------------------------------------------------------------
 .../java/org/apache/kylin/rest/service/JobService.java    | 10 ----------
 1 file changed, 10 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/44f9ba56/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java
----------------------------------------------------------------------
diff --git a/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java b/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java
index 589f67d..bc4d89c 100644
--- a/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java
+++ b/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java
@@ -206,7 +206,6 @@ public class JobService extends BasicService {
         }
 
         checkCubeDescSignature(cube);
-        checkNoRunningJob(cube);
 
         DefaultChainedExecutable job;
 
@@ -236,15 +235,6 @@ public class JobService extends BasicService {
             throw new IllegalStateException("Inconsistent cube desc signature for " + cube.getDescriptor());
     }
 
-    private void checkNoRunningJob(CubeInstance cube) throws JobException {
-        final List<CubingJob> cubingJobs = listAllCubingJobs(cube.getName(), null,
EnumSet.allOf(ExecutableState.class));
-        for (CubingJob job : cubingJobs) {
-            if (job.getStatus() == ExecutableState.READY || job.getStatus() == ExecutableState.RUNNING
|| job.getStatus() == ExecutableState.ERROR) {
-                throw new JobException("The cube " + cube.getName() + " has running job("
+ job.getId() + ") please discard it and try again.");
-            }
-        }
-    }
-
     public JobInstance getJobInstance(String uuid) throws IOException, JobException {
         return getSingleJobInstance(getExecutableManager().getJob(uuid));
     }


Mime
View raw message