KYLIN-2187 make it possible to monitor more type jobs Signed-off-by: Li Yang <[email protected]>
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 <[email protected]> Authored: Tue Nov 15 18:49:06 2016 +0800 Committer: Li Yang <[email protected]> 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>() {
