Merge pull request #184 from spotify/live-wire/race

It is possible that the job succeeded but submitter is still running
spotify · Jun 28, 2022 · 7537bed · 7537bed
2 parents 9ae6905 + 4826f48
commit 7537bed
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/flink/handler.go b/pkg/flink/handler.go
@@ -265,6 +265,9 @@ func flinkClusterJobPhaseInfo(ctx context.Context, jobStatus *flinkOp.JobStatus,
 	case flinkOp.JobStateUpdating, flinkOp.JobStatePending, flinkOp.JobStateDeploying, flinkOp.JobStateRestarting:
 		return pluginsCore.PhaseInfoInitializing(occurredAt, pluginsCore.DefaultPhaseVersion, msg, info)
 	case flinkOp.JobStateSucceeded:
+		if jobStatus.SubmitterExitCode < 0 {
+			return pluginsCore.PhaseInfoRunning(pluginsCore.DefaultPhaseVersion, info)
+		}
 		if jobStatus.SubmitterExitCode == 0 {
 			return pluginsCore.PhaseInfoSuccess(info)
 		}