Correct num of failures (#3722)

* set number of failed attempts correctly * set number of failed attempts correctly
apache · Jul 24, 2023 · 14262c1 · 14262c1
1 parent 0151890
commit 14262c1
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -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();