logicamp/flink-kube-operator
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: resolve job start after pause bug

Browse Source
This commit is contained in:
Mohamad Khani 2025-01-17 21:09:53 +03:30
parent 5066dc650f
commit 322877ad8e
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/managed_job/pause.go
View File

@ -33,7 +33,7 @@ func (job *ManagedJob) Pause() error {
if savepointPath != "" { if savepointPath != "" {
job.def.Status.LastSavepointPath = &savepointPath job.def.Status.LastSavepointPath = &savepointPath
job.def.Status.PauseSavepointTriggerId = nil job.def.Status.PauseSavepointTriggerId = nil
job.def.Status.JobStatus = "" job.def.Status.JobStatus = "FINISHED"
job.def.Status.LastSavepointPath = &savepointPath job.def.Status.LastSavepointPath = &savepointPath
lastSavepointDate := time.Now() lastSavepointDate := time.Now()
job.def.Status.LastSavepointDate = &lastSavepointDate job.def.Status.LastSavepointDate = &lastSavepointDate