You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2016/07/14 13:47:20 UTC
kylin git commit: KYLIN-1827 Send mail notification when runtime
exception throws during build/merge cube
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 <sh...@apache.org>
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 <ga...@ebay.com>
Authored: Thu Jul 14 17:49:23 2016 +0800
Committer: shaofengshi <sh...@apache.org>
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());