fix log level

lyft · May 15, 2023 · 9072e02 · 9072e02
1 parent 46c26e7
commit 9072e02
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
@@ -773,7 +773,8 @@ func (s *FlinkStateMachine) handleSubmittingJob(ctx context.Context, app *v1beta
 	logger.Info(ctx, "Monitoring job vertices with timeout ", flinkJobVertexTimeout)
 	jobStarted, err := monitorJobStart(job, flinkJobVertexTimeout)
 	if err != nil {
-		logger.Errorf(ctx, "Job monitoring failed with error: %v", err)
+		logger.Info(ctx, "Job monitoring failed with error: %v", err)
+		s.flinkController.LogEvent(ctx, app, corev1.EventTypeWarning, "JobMonitoringFailed", err.Error())
 		return statusUnchanged, err
 	}
 	if jobStarted {