You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2016/10/20 09:30:46 UTC
kylin git commit: KYLIN-2070 remove check on building job
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 <sh...@apache.org>
Authored: Thu Oct 20 17:30:15 2016 +0800
Committer: shaofengshi <sh...@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));
}