Fix job submitter status nil pointer access (#446)

Co-authored-by: Barna Kutassy <[email protected]>
spotify · Aug 4, 2022 · 53df4ad · 53df4ad
1 parent 9ffed40
commit 53df4ad
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/controllers/flinkcluster/flinkcluster_observer.go b/controllers/flinkcluster/flinkcluster_observer.go
@@ -112,10 +112,10 @@ func (s *FlinkJobSubmitter) getState() JobSubmitState {
 		return JobDeployStateSucceeded
 	// Job ID not found cases:
 	// Failed and job ID not found.
-	case s.job.Status.Failed > 0:
+	case s.job != nil && s.job.Status.Failed > 0:
 		return JobDeployStateFailed
 	// Ongoing job submission.
-	case s.job.Status.Succeeded == 0 && s.job.Status.Failed == 0:
+	case s.job != nil && s.job.Status.Succeeded == 0 && s.job.Status.Failed == 0:
 		fallthrough
 	// Finished, but failed to extract log.
 	case s.log == nil: