Repository: kylin Updated Branches: refs/heads/master ef740132f -> 86ddae64a
KYLIN-1827 Send mail notification when runtime exception throws during build/merge cube Signed-off-by: shaofengshi <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/86ddae64 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/86ddae64 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/86ddae64 Branch: refs/heads/master Commit: 86ddae64a1f3d46631d1c80ebc26499695b993e9 Parents: ef74013 Author: Ma,Gang <[email protected]> Authored: Thu Jul 14 17:49:23 2016 +0800 Committer: shaofengshi <[email protected]> Committed: Thu Jul 14 21:44:10 2016 +0800 ---------------------------------------------------------------------- .../apache/kylin/job/execution/DefaultChainedExecutable.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/86ddae64/core-job/src/main/java/org/apache/kylin/job/execution/DefaultChainedExecutable.java ---------------------------------------------------------------------- diff --git a/core-job/src/main/java/org/apache/kylin/job/execution/DefaultChainedExecutable.java b/core-job/src/main/java/org/apache/kylin/job/execution/DefaultChainedExecutable.java index 61a30f0..b4c3adc 100644 --- a/core-job/src/main/java/org/apache/kylin/job/execution/DefaultChainedExecutable.java +++ b/core-job/src/main/java/org/apache/kylin/job/execution/DefaultChainedExecutable.java @@ -73,6 +73,12 @@ public class DefaultChainedExecutable extends AbstractExecutable implements Chai } @Override + protected void onExecuteError(Throwable exception, ExecutableContext executableContext) { + super.onExecuteError(exception,executableContext); + notifyUserStatusChange(executableContext, ExecutableState.ERROR); + } + + @Override protected void onExecuteFinished(ExecuteResult result, ExecutableContext executableContext) { if (isDiscarded()) { setEndTime(System.currentTimeMillis());
