From b84a5faaaeda9e4011d93df96a77da79e7770071 Mon Sep 17 00:00:00 2001 From: Antonio Ojea Date: Wed, 14 Sep 2022 17:26:07 +0200 Subject: [PATCH] kube-proxy use debug log level for cache operations Level 4 is mean for debug operations. The default level use to be level 2, on clusters with a lot of Services this means that the kube-proxy will generate a lot of noise on the logs, with the performance penalty associated to it. --- pkg/proxy/service.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/proxy/service.go b/pkg/proxy/service.go index 01ae6a69a6d..c3b1f2b8013 100644 --- a/pkg/proxy/service.go +++ b/pkg/proxy/service.go @@ -322,7 +322,7 @@ func (sct *ServiceChangeTracker) Update(previous, current *v1.Service) bool { if reflect.DeepEqual(change.previous, change.current) { delete(sct.items, namespacedName) } else { - klog.V(2).InfoS("Service updated ports", "service", klog.KObj(svc), "portCount", len(change.current)) + klog.V(4).InfoS("Service updated ports", "service", klog.KObj(svc), "portCount", len(change.current)) } metrics.ServiceChangesPending.Set(float64(len(sct.items))) return len(sct.items) > 0 @@ -438,9 +438,9 @@ func (sm *ServiceMap) merge(other ServiceMap) sets.String { existingPorts.Insert(svcPortName.String()) _, exists := (*sm)[svcPortName] if !exists { - klog.V(1).InfoS("Adding new service port", "portName", svcPortName, "servicePort", info) + klog.V(4).InfoS("Adding new service port", "portName", svcPortName, "servicePort", info) } else { - klog.V(1).InfoS("Updating existing service port", "portName", svcPortName, "servicePort", info) + klog.V(4).InfoS("Updating existing service port", "portName", svcPortName, "servicePort", info) } (*sm)[svcPortName] = info } @@ -463,7 +463,7 @@ func (sm *ServiceMap) unmerge(other ServiceMap, UDPStaleClusterIP sets.String) { for svcPortName := range other { info, exists := (*sm)[svcPortName] if exists { - klog.V(1).InfoS("Removing service port", "portName", svcPortName) + klog.V(4).InfoS("Removing service port", "portName", svcPortName) if info.Protocol() == v1.ProtocolUDP { UDPStaleClusterIP.Insert(info.ClusterIP().String()) }