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 6e47cc482b9..3f2570c68f5 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 @@ -608,6 +608,8 @@ public WorkUnit apply(@Nullable WorkUnit input) { String errMsg = "Failed to launch and run job " + jobId + " due to " + t.getMessage(); LOG.error(errMsg + ": " + t, t); this.jobContext.getJobState().setJobFailureException(t); + jobState.setProp(ConfigurationKeys.JOB_FAILURES_KEY, + Integer.parseInt(jobState.getProp(ConfigurationKeys.JOB_FAILURES_KEY, "0")) + 1); } finally { try { troubleshooter.refineIssues();