Fix Job status SubmitterName (#140)

spotify · Oct 20, 2021 · 16a1830 · 16a1830
1 parent d91b969
commit 16a1830
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/controllers/flinkcluster_updater.go b/controllers/flinkcluster_updater.go
@@ -540,10 +540,12 @@ func (updater *ClusterStatusUpdater) deriveJobStatus() *v1beta1.JobStatus {
 		newJob = oldJob.DeepCopy()
 	} else {
 		newJob = new(v1beta1.JobStatus)
-		if observedSubmitter.job != nil {
-			newJob.SubmitterName = observedSubmitter.job.Name
-		}
 	}
+
+	if observedSubmitter.job != nil {
+		newJob.SubmitterName = observedSubmitter.job.Name
+	}
+
 	var newJobState string
 	switch {
 	case oldJob == nil: