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

fix: resolve savepoint trigger no SavepointTriggerId problem

Browse Source
This commit is contained in:
Mohamad Khani
2025-01-18 00:31:05 +03:30
parent 8f3c32ed95
commit 6591748d16
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/managed_job/savepoint.go
View File

@@ -24,7 +24,7 @@ func (job ManagedJob) createSavepoint() error {
return err return err
} }
pkg.Logger.Debug("[managed-job] [savepoint] savepoint created successfully", zap.String("trigger-id", resp.RequestID)) pkg.Logger.Debug("[managed-job] [savepoint] savepoint created successfully", zap.String("trigger-id", resp.RequestID))
job.def.Status.SavepointTriggerId = &resp.RequestID
job.crd.Patch(job.def.UID, map[string]interface{}{ job.crd.Patch(job.def.UID, map[string]interface{}{
"status": map[string]interface{}{ "status": map[string]interface{}{
"savepointTriggerId": resp.RequestID, "savepointTriggerId": resp.RequestID,