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 <liy...@apache.org> Authored: Tue Nov 8 23:16:06 2016 +0800 Committer: Yang Li <liy...@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())) {
