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/08 15:16:22 UTC
kylin git commit: KYLIN-2169 fix bug..
Repository: kylin
Updated Branches:
refs/heads/master 0c6aa760e -> 82c2e5dba
KYLIN-2169 fix bug..
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/82c2e5db
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/82c2e5db
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/82c2e5db
Branch: refs/heads/master
Commit: 82c2e5dba0d4783714c2e55c7407f3170f2e94c0
Parents: 0c6aa76
Author: Yang Li <li...@apache.org>
Authored: Tue Nov 8 23:16:06 2016 +0800
Committer: Yang Li <li...@apache.org>
Committed: Tue Nov 8 23:16:06 2016 +0800
----------------------------------------------------------------------
engine-mr/src/main/java/org/apache/kylin/engine/mr/CubingJob.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/82c2e5db/engine-mr/src/main/java/org/apache/kylin/engine/mr/CubingJob.java
----------------------------------------------------------------------
diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/CubingJob.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/CubingJob.java
index bce0433..c3ee36c 100644
--- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/CubingJob.java
+++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/CubingJob.java
@@ -123,7 +123,7 @@ public class CubingJob extends DefaultChainedExecutable {
@Override
protected Pair<String, String> formatNotifications(ExecutableContext context, ExecutableState state) {
CubeInstance cubeInstance = CubeManager.getInstance(context.getConfig()).getCube(CubingExecutableUtil.getCubeName(this.getParams()));
- final Output output = jobService.getOutput(getId());
+ final Output output = getManager().getOutput(getId());
String logMsg;
state = output.getState();
if (state != ExecutableState.ERROR && !cubeInstance.getDescriptor().getStatusNeedNotify().contains(state.toString())) {