You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by le...@apache.org on 2021/06/01 18:38:44 UTC
[gobblin] branch master updated: Send failed timer instead of
success timer when job is cancelled
This is an automated email from the ASF dual-hosted git repository.
lesun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new d936c25 Send failed timer instead of success timer when job is cancelled
d936c25 is described below
commit d936c25c0757bcc37e07b4e7a968619275a639bb
Author: Jack Moseley <jm...@linkedin.com>
AuthorDate: Mon May 24 12:06:44 2021 -0700
Send failed timer instead of success timer when job is cancelled
---
.../src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java
index f7055f9..a120a36 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java
@@ -598,7 +598,7 @@ public abstract class AbstractJobLauncher implements JobLauncher {
}
});
- if (jobState.getState() == JobState.RunningState.FAILED) {
+ if (jobState.getState() == JobState.RunningState.FAILED || jobState.getState() == JobState.RunningState.CANCELLED) {
notifyListeners(this.jobContext, jobListener, TimingEvent.LauncherTimings.JOB_FAILED, new JobListenerAction() {
@Override
public void apply(JobListener jobListener, JobContext jobContext)