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/KYLIN-1971 Commit: 44f9ba56671e634916c6b7ba5759c1f09cbb9afc Parents: b9fdab7 Author: shaofengshi <shaofeng...@apache.org> Authored: Thu Oct 20 17:30:15 2016 +0800 Committer: shaofengshi <shaofeng...@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)); }
