From 699cf12f72bb1d3f45c2def79e9e746b1405c39b Mon Sep 17 00:00:00 2001 From: Mohammadreza Khani Date: Fri, 13 Dec 2024 15:11:36 +0330 Subject: [PATCH] fix(savepoint): periodically savepoint bug --- internal/managed_job/savepoint.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/internal/managed_job/savepoint.go b/internal/managed_job/savepoint.go index 377666d..0eb4058 100644 --- a/internal/managed_job/savepoint.go +++ b/internal/managed_job/savepoint.go @@ -43,8 +43,9 @@ func (job ManagedJob) trackSavepoint() error { return v1alpha1.ErrNoSavepointTriggerId } resp, err := job.client.TrackSavepoint(*job.def.Status.JobId, *job.def.Status.SavepointTriggerId) - pkg.Logger.Debug("[managed-job] [savepoint] track savepoint", + pkg.Logger.Info("[managed-job] [savepoint] savepoint track result", zap.Any("status.Id", resp.Status.Id), + zap.Any("path", resp.Operation.Location), zap.Any("failureCause.stacktrace", resp.Operation.FailureCause.StackTrace), zap.Any("failureCause.class", resp.Operation.FailureCause.Class), zap.Error(err), @@ -69,8 +70,9 @@ func (job ManagedJob) trackSavepoint() error { if resp.Status.Id == api.SavepointStatusInCompleted { job.crd.Patch(job.def.UID, map[string]interface{}{ "status": map[string]interface{}{ - "lastSavepointPath": resp.Operation.Location, - "lastSavepointDate": time.Now().Format(time.RFC3339), + "savepointTriggerId": nil, + "lastSavepointPath": resp.Operation.Location, + "lastSavepointDate": time.Now().Format(time.RFC3339), }, }) }