Merge pull request #15659 from cdapio/CDAP-21041-cherrypick

[🍒][CDAP-21041] add dataproc job status when stopped or failed
cdapio · Jul 25, 2024 · 8fe1fad · 8fe1fad
2 parents 13311c4 + d06363d
commit 8fe1fad
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/.../main/java/io/cdap/cdap/runtime/spi/provisioner/dataproc/AbstractDataprocProvisioner.java b/.../main/java/io/cdap/cdap/runtime/spi/provisioner/dataproc/AbstractDataprocProvisioner.java
@@ -121,12 +121,13 @@ public final ClusterStatus deleteClusterWithStatus(ProvisionerContext context, C
         }
 
         if (jobDetail != null
-            && jobDetail.getStatus() == RuntimeJobStatus.FAILED
+            && jobDetail.getStatus() != RuntimeJobStatus.COMPLETED
             && (jobDetail instanceof DataprocRuntimeJobDetail)) {
           // Status details is specific to dataproc jobs, so it was not added to RuntimeJobDetail spi.
           String statusDetails = ((DataprocRuntimeJobDetail) jobDetail).getJobStatusDetails();
           if (statusDetails != null) {
-            LOG.error("Dataproc job failed with the status details: {}", statusDetails);
+            LOG.error("Dataproc job '{}' with the status details: {}",
+                jobDetail.getStatus().name(), statusDetails);
           }
         }
       } finally {