From 4826f4801d67e5c35e0c1ba7db834e4e75108c37 Mon Sep 17 00:00:00 2001 From: live-wire Date: Tue, 28 Jun 2022 14:04:55 +0200 Subject: [PATCH] It is possible that the job succeeded but submitter is still running --- pkg/flink/handler.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/flink/handler.go b/pkg/flink/handler.go index 456c5dc..403b709 100644 --- 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) }