diff --git a/cmd/operator/main.go b/cmd/operator/main.go
index d4cb1c5..b2d8ab5 100644
--- a/cmd/operator/main.go
+++ b/cmd/operator/main.go
@@ -3,11 +3,12 @@ package main
 import (
 	"flink-kube-operator/internal/crd"
 	"flink-kube-operator/internal/manager"
-	"fmt"
+	"flink-kube-operator/pkg"
 	"log"
 	"os"
 
 	api "github.com/logi-camp/go-flink-client"
+	"go.uber.org/zap"
 )
 
 func main() {
@@ -26,7 +27,7 @@ func main() {
 	if err != nil {
 		panic(err)
 	}
-	fmt.Println(clusterConfig)
+	pkg.Logger.Info("[main]", zap.Any("cluster-config", clusterConfig))
 
 	// init flink job manager
 	manager.NewManager(c, crdInstance)
diff --git a/internal/crd/watch.go b/internal/crd/watch.go
index 12b3b2a..fd4e7b9 100644
--- a/internal/crd/watch.go
+++ b/internal/crd/watch.go
@@ -50,7 +50,7 @@ func (crd Crd) watchFlinkJobs() rxgo.Observable {
 			switch event.Type {
 			case watch.Bookmark:
 			case watch.Modified:
-				pkg.Logger.Info("[crd] [watch] flink job updated", zap.String("jobName", job.GetName()))
+				pkg.Logger.Info("[crd] [watch] flink job modified", zap.String("jobName", job.GetName()))
 				crd.repsert(job)
 			case watch.Added:
 				pkg.Logger.Info("[crd] [watch] new flink job created")
diff --git a/pkg/logger.go b/pkg/logger.go
index 7595fd0..67ff770 100644
--- a/pkg/logger.go
+++ b/pkg/logger.go
@@ -34,7 +34,7 @@ func createOrUpdateInstance(config LoggerConfig) *zap.Logger {
 		createFileCore(config),
 		createStdoutCore(config),
 	)
-	loggerInstance = zap.New(core, zap.AddCaller()).WithOptions(
+	loggerInstance = zap.New(core).WithOptions(
 		zap.IncreaseLevel(config.Level),
 	)
 	return loggerInstance