Fix: set FailureReasons when job failed (#171)

spotify · Dec 9, 2021 · 93f1f1c · 93f1f1c
1 parent ac86388
commit 93f1f1c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/controllers/flinkcluster_updater.go b/controllers/flinkcluster_updater.go
@@ -625,6 +625,7 @@ func (updater *ClusterStatusUpdater) deriveJobStatus() *v1beta1.JobStatus {
 			if newJob.State == v1beta1.JobStateLost && oldJob.FinalSavepoint {
 				newJob.FinalSavepoint = false
 			}
+			fallthrough
 		case newJob.IsFailed():
 			if len(newJob.FailureReasons) == 0 {
 				newJob.FailureReasons = []string{}