diff --git a/pkg/util/helper/workstatus.go b/pkg/util/helper/workstatus.go index 828186e6f..8c8c9cd3c 100644 --- a/pkg/util/helper/workstatus.go +++ b/pkg/util/helper/workstatus.go @@ -28,7 +28,7 @@ func AggregateResourceBindingWorkStatus(c client.Client, binding *workv1alpha1.R } if reflect.DeepEqual(binding.Status.AggregatedStatus, aggregatedStatuses) { - klog.Infof("New aggregatedStatuses are equal with old resourceBinding(%s/%s) AggregatedStatus, no update required.", + klog.V(4).Infof("New aggregatedStatuses are equal with old resourceBinding(%s/%s) AggregatedStatus, no update required.", binding.Namespace, binding.Name) return nil } diff --git a/pkg/util/objectwatcher/objectwatcher.go b/pkg/util/objectwatcher/objectwatcher.go index 6f4f9c422..1af920abb 100644 --- a/pkg/util/objectwatcher/objectwatcher.go +++ b/pkg/util/objectwatcher/objectwatcher.go @@ -52,7 +52,6 @@ func NewObjectWatcher(client client.Client, kubeClientSet kubernetes.Interface, } func (o *objectWatcherImpl) Create(clusterName string, desireObj *unstructured.Unstructured) error { - klog.Infof("Start to create resource %v/%v", desireObj.GetNamespace(), desireObj.GetName()) dynamicClusterClient, err := util.BuildDynamicClusterClient(o.Client, o.KubeClientSet, clusterName) if err != nil { klog.Errorf("Failed to build dynamic cluster client for cluster %s.", clusterName) @@ -73,6 +72,7 @@ func (o *objectWatcherImpl) Create(clusterName string, desireObj *unstructured.U klog.Errorf("Failed to create resource %v, err is %v ", desireObj.GetName(), err) return err } + klog.Infof("Created resource(kind=%s, %s/%s) on cluster: %s", desireObj.GetKind(), desireObj.GetNamespace(), desireObj.GetName(), clusterName) // record version o.recordVersion(clusterObj, dynamicClusterClient.ClusterName) @@ -80,7 +80,6 @@ func (o *objectWatcherImpl) Create(clusterName string, desireObj *unstructured.U } func (o *objectWatcherImpl) Update(clusterName string, desireObj, clusterObj *unstructured.Unstructured) error { - klog.Infof("Start to update resource %v/%v", desireObj.GetNamespace(), desireObj.GetName()) dynamicClusterClient, err := util.BuildDynamicClusterClient(o.Client, o.KubeClientSet, clusterName) if err != nil { klog.Errorf("Failed to build dynamic cluster client for cluster %s.", clusterName) @@ -105,13 +104,14 @@ func (o *objectWatcherImpl) Update(clusterName string, desireObj, clusterObj *un return err } + klog.Infof("Updated resource(kind=%s, %s/%s) on cluster: %s", desireObj.GetKind(), desireObj.GetNamespace(), desireObj.GetName(), clusterName) + // record version o.recordVersion(resource, clusterName) return nil } func (o *objectWatcherImpl) Delete(clusterName string, desireObj *unstructured.Unstructured) error { - klog.Infof("Start to delete resource %v/%v", desireObj.GetNamespace(), desireObj.GetName()) dynamicClusterClient, err := util.BuildDynamicClusterClient(o.Client, o.KubeClientSet, clusterName) if err != nil { klog.Errorf("Failed to build dynamic cluster client for cluster %s.", clusterName) @@ -132,6 +132,7 @@ func (o *objectWatcherImpl) Delete(clusterName string, desireObj *unstructured.U klog.Errorf("Failed to delete resource %v, err is %v ", desireObj.GetName(), err) return err } + klog.Infof("Deleted resource(kind=%s, %s/%s) on cluster: %s", desireObj.GetKind(), desireObj.GetNamespace(), desireObj.GetName(), clusterName) objectKey := o.genObjectKey(desireObj) o.deleteVersionRecord(dynamicClusterClient.ClusterName, objectKey) diff --git a/pkg/util/worker.go b/pkg/util/worker.go index b1c4f3431..f914b3ba8 100644 --- a/pkg/util/worker.go +++ b/pkg/util/worker.go @@ -111,7 +111,8 @@ func GenerateKey(obj interface{}) (QueueKey, error) { func getClusterNameFromLabel(resource *unstructured.Unstructured) (string, error) { workNamespace := GetLabelValue(resource.GetLabels(), WorkNamespaceLabel) if len(workNamespace) == 0 { - klog.Infof("Resource(%s/%s/%s) not created by karmada", resource.GetKind(), resource.GetNamespace(), resource.GetName()) + klog.V(4).Infof("Ignore resource(%s/%s/%s) which not managed by karmada", resource.GetKind(), resource.GetNamespace(), resource.GetName()) + return "", nil } cluster, err := names.GetClusterName(workNamespace)