From 1ff69e086f2414401a7761d24b5f2fbbc74de2df Mon Sep 17 00:00:00 2001
From: Mohammadreza Khani <mohamadkhani14@gmail.com>
Date: Sat, 25 Jan 2025 01:05:17 +0330
Subject: [PATCH] fix(log): add log

---
 internal/crd/watch.go             | 2 +-
 internal/managed_job/savepoint.go | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/crd/watch.go b/internal/crd/watch.go
index c7ab767..3c56b7f 100644
--- a/internal/crd/watch.go
+++ b/internal/crd/watch.go
@@ -47,6 +47,7 @@ func (crd Crd) watchFlinkJobs() rxgo.Observable {
 					Job:       job,
 				},
 			}
+			pkg.Logger.Debug("[crd] [watch] change in", zap.String("name", job.Name))
 			switch event.Type {
 			case watch.Bookmark:
 			case watch.Modified:
@@ -57,7 +58,6 @@ func (crd Crd) watchFlinkJobs() rxgo.Observable {
 				crd.repsert(job)
 			case watch.Deleted:
 				crd.remove(job.UID)
-
 			}
 		}
 
diff --git a/internal/managed_job/savepoint.go b/internal/managed_job/savepoint.go
index 9e61c1c..53e7175 100644
--- a/internal/managed_job/savepoint.go
+++ b/internal/managed_job/savepoint.go
@@ -17,7 +17,7 @@ func (job ManagedJob) createSavepoint() error {
 		pkg.Logger.Debug("[managed-job] [savepoint] no job id")
 		return v1alpha1.ErrNoJobId
 	}
-	pkg.Logger.Info("[managed-job] [savepoint] creating savepoint", zap.String("interval", job.def.Spec.SavepointInterval.String()))
+	pkg.Logger.Info("[managed-job] [savepoint] creating savepoint", zap.String("name", job.def.GetName()), zap.String("interval", job.def.Spec.SavepointInterval.String()))
 	resp, err := job.client.SavePoints(*job.def.Status.JobId, os.Getenv("SAVEPOINT_PATH"), false)
 	if err != nil {
 		pkg.Logger.Error("[managed-job] [savepoint] error in creating savepoint", zap.Error(err))