Skip to content

Commit

Permalink
rename method
Browse files Browse the repository at this point in the history
  • Loading branch information
sethsaperstein-lyft committed May 16, 2023
1 parent 9072e02 commit 1a44de0
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/controller/flinkapplication/flink_state_machine.go
Original file line number Diff line number Diff line change
Expand Up @@ -771,7 +771,7 @@ func (s *FlinkStateMachine) handleSubmittingJob(ctx context.Context, app *v1beta
cfg := config.GetConfig()
flinkJobVertexTimeout := cfg.FlinkJobVertexTimeout
logger.Info(ctx, "Monitoring job vertices with timeout ", flinkJobVertexTimeout)
jobStarted, err := monitorJobStart(job, flinkJobVertexTimeout)
jobStarted, err := monitorJobSubmission(job, flinkJobVertexTimeout)
if err != nil {
logger.Info(ctx, "Job monitoring failed with error: %v", err)
s.flinkController.LogEvent(ctx, app, corev1.EventTypeWarning, "JobMonitoringFailed", err.Error())
Expand All @@ -783,7 +783,7 @@ func (s *FlinkStateMachine) handleSubmittingJob(ctx context.Context, app *v1beta
return statusUnchanged, err
}

func monitorJobStart(job *client.FlinkJobOverview, timeout config2.Duration) (bool, error) {
func monitorJobSubmission(job *client.FlinkJobOverview, timeout config2.Duration) (bool, error) {
jobStartTime := getJobStartTimeInUTC(job.StartTime)
now := time.Now().UTC()
shouldContinueMonitoring := now.Before(jobStartTime.Add(timeout.Duration))
Expand Down

0 comments on commit 1a44de0

Please sign in to comment.