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

fix: wrong life-cycle-status after job failed

Browse Source
This commit is contained in:
Mohamad Khani 2024-12-18 11:12:08 +03:30
parent 5bc047dbd1
commit 7e33fd6cef
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/managed_job/cycle.go
View File

@ -41,6 +41,12 @@ func (job *ManagedJob) Cycle() {
if job.def.Status.JobStatus == v1alpha1.JobStatusCreating { if job.def.Status.JobStatus == v1alpha1.JobStatusCreating {
return return
} }
if job.def.Status.JobStatus == v1alpha1.JobStatusFailed {
job.def.Status.LifeCycleStatus = v1alpha1.LifeCycleStatusFailed
job.crd.SetJobStatus(job.def.UID, job.def.Status)
return
}
// if job.def.Status.JobStatus == v1alpha1.JobStatusFailed && job.def.Status.LastSavepointPath != nil { // if job.def.Status.JobStatus == v1alpha1.JobStatusFailed && job.def.Status.LastSavepointPath != nil {
// //job.restore() // //job.restore()
// return // return