Change app status to rollback

lyft · Dec 18, 2023 · 7b0bf33 · 7b0bf33
1 parent e0a2885
commit 7b0bf33
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/controller/flinkapplication/flink_state_machine.go b/pkg/controller/flinkapplication/flink_state_machine.go
@@ -784,7 +784,8 @@ func (s *FlinkStateMachine) handleSubmittingJob(ctx context.Context, app *v1beta
 	if err != nil {
 		logger.Info(ctx, "Job monitoring failed with error: %v", err)
 		s.flinkController.LogEvent(ctx, app, corev1.EventTypeWarning, "JobMonitoringFailed", err.Error())
-		return statusUnchanged, err
+		s.updateApplicationPhase(app, v1beta1.FlinkApplicationRollingBackJob)
+		return statusChanged, err
 	}
 	if jobStarted {
 		return updateJobAndReturn(ctx, s, app, hash)