You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2016/11/16 03:07:37 UTC
[2/5] kylin git commit: KYLIN-2187 make it possible to monitor more
type jobs
KYLIN-2187 make it possible to monitor more type jobs
Signed-off-by: Li Yang <li...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/d1c0b585
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/d1c0b585
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/d1c0b585
Branch: refs/heads/master
Commit: d1c0b58598c26a7b4ce3c52717fd723839d4cf95
Parents: 546ea24
Author: Cheng Wang <ch...@kyligence.io>
Authored: Tue Nov 15 18:49:06 2016 +0800
Committer: Li Yang <li...@apache.org>
Committed: Wed Nov 16 10:33:57 2016 +0800
----------------------------------------------------------------------
.../main/java/org/apache/kylin/rest/service/BasicService.java | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/d1c0b585/server-base/src/main/java/org/apache/kylin/rest/service/BasicService.java
----------------------------------------------------------------------
diff --git a/server-base/src/main/java/org/apache/kylin/rest/service/BasicService.java b/server-base/src/main/java/org/apache/kylin/rest/service/BasicService.java
index 9f14deb..d83ae28 100644
--- a/server-base/src/main/java/org/apache/kylin/rest/service/BasicService.java
+++ b/server-base/src/main/java/org/apache/kylin/rest/service/BasicService.java
@@ -29,16 +29,14 @@ import org.apache.kylin.cube.CubeDescManager;
import org.apache.kylin.cube.CubeManager;
import org.apache.kylin.engine.mr.CubingJob;
import org.apache.kylin.engine.mr.steps.CubingExecutableUtil;
-import org.apache.kylin.metadata.streaming.StreamingManager;
import org.apache.kylin.job.execution.AbstractExecutable;
import org.apache.kylin.job.execution.ExecutableManager;
import org.apache.kylin.job.execution.ExecutableState;
import org.apache.kylin.job.execution.Output;
import org.apache.kylin.metadata.MetadataManager;
import org.apache.kylin.metadata.badquery.BadQueryHistoryManager;
-import org.apache.kylin.metadata.project.ProjectInstance;
import org.apache.kylin.metadata.project.ProjectManager;
-import org.apache.kylin.metadata.realization.RealizationType;
+import org.apache.kylin.metadata.streaming.StreamingManager;
import org.apache.kylin.source.kafka.KafkaConfigManager;
import org.apache.kylin.storage.hybrid.HybridManager;
@@ -124,8 +122,7 @@ public abstract class BasicService {
if (null == projectName || null == getProjectManager().getProject(projectName)) {
return true;
} else {
- ProjectInstance project = getProjectManager().getProject(projectName);
- return project.containsRealization(RealizationType.CUBE, CubingExecutableUtil.getCubeName(executable.getParams()));
+ return projectName.equals(executable.getParams().get("projectName"));
}
}
}, new Predicate<CubingJob>() {