Repository: falcon Updated Branches: refs/heads/0.10 7d7b1fb16 -> 248c92935
FALCON-2018 WorkflowJobNotification sends incorrect message for kille⦠â¦d instances Author: Praveen Adlakha <[email protected]> Reviewers: "Balu Vellanki <[email protected]>" Closes #179 from PraveenAdlakha/2018 (cherry picked from commit a4e18a4d428569c37e65e281c3c36bf3ed737eed) Signed-off-by: bvellanki <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/248c9293 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/248c9293 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/248c9293 Branch: refs/heads/0.10 Commit: 248c92935915f3c1f1e8bcaa942c15760c3ffdf5 Parents: 7d7b1fb Author: Praveen Adlakha <[email protected]> Authored: Wed Jun 8 11:10:15 2016 -0700 Committer: bvellanki <[email protected]> Committed: Wed Jun 8 11:10:30 2016 -0700 ---------------------------------------------------------------------- .../apache/falcon/workflow/WorkflowJobEndNotificationService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/248c9293/common/src/main/java/org/apache/falcon/workflow/WorkflowJobEndNotificationService.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/falcon/workflow/WorkflowJobEndNotificationService.java b/common/src/main/java/org/apache/falcon/workflow/WorkflowJobEndNotificationService.java index b692258..fbd1e3f 100644 --- a/common/src/main/java/org/apache/falcon/workflow/WorkflowJobEndNotificationService.java +++ b/common/src/main/java/org/apache/falcon/workflow/WorkflowJobEndNotificationService.java @@ -299,7 +299,7 @@ public class WorkflowJobEndNotificationService implements FalconService { } Long duration = (endTime.getTime() - startTime.getTime()) * 1000000; - if (context.hasWorkflowFailed()) { + if (!context.hasWorkflowSucceeded()) { GenericAlert.instrumentFailedInstance(clusterName, entityType, entityName, nominalTime, workflowId, workflowUser, runId, operation, SchemaHelper.formatDateUTC(startTime), "", "", duration);
