diff --git a/pkg/proxy/iptables/proxier.go b/pkg/proxy/iptables/proxier.go index 4b7b44601cb..87b907d21ab 100644 --- a/pkg/proxy/iptables/proxier.go +++ b/pkg/proxy/iptables/proxier.go @@ -1110,7 +1110,7 @@ func (proxier *Proxier) syncProxyRules() { } else { socket, err := proxier.portMapper.OpenLocalPort(&lp) if err != nil { - msg := fmt.Sprintf("can't open %s, skipping this externalIP: %v", lp.String(), err) + msg := fmt.Sprintf("can't open port %s, skipping it", lp.String()) proxier.recorder.Eventf( &v1.ObjectReference{ @@ -1119,7 +1119,7 @@ func (proxier *Proxier) syncProxyRules() { UID: types.UID(proxier.hostname), Namespace: "", }, v1.EventTypeWarning, err.Error(), msg) - klog.ErrorS(err, "can't open port, skipping externalIP", "port", lp.String()) + klog.ErrorS(err, "can't open port, skipping it", "port", lp.String()) continue } klog.V(2).InfoS("Opened local port", "port", lp.String()) @@ -1283,7 +1283,7 @@ func (proxier *Proxier) syncProxyRules() { } else if svcInfo.Protocol() != v1.ProtocolSCTP { socket, err := proxier.portMapper.OpenLocalPort(&lp) if err != nil { - msg := fmt.Sprintf("can't open %s, skipping this nodePort: %v", lp.String(), err) + msg := fmt.Sprintf("can't open port %s, skipping it", lp.String()) proxier.recorder.Eventf( &v1.ObjectReference{ @@ -1292,7 +1292,7 @@ func (proxier *Proxier) syncProxyRules() { UID: types.UID(proxier.hostname), Namespace: "", }, v1.EventTypeWarning, err.Error(), msg) - klog.ErrorS(err, "can't open port, skipping this nodePort", "port", lp.String()) + klog.ErrorS(err, "can't open port, skipping it", "port", lp.String()) continue } klog.V(2).InfoS("Opened local port", "port", lp.String()) diff --git a/pkg/proxy/ipvs/proxier.go b/pkg/proxy/ipvs/proxier.go index 208337940c3..6618447ec9c 100644 --- a/pkg/proxy/ipvs/proxier.go +++ b/pkg/proxy/ipvs/proxier.go @@ -1263,7 +1263,7 @@ func (proxier *Proxier) syncProxyRules() { } else { socket, err := proxier.portMapper.OpenLocalPort(&lp) if err != nil { - msg := fmt.Sprintf("can't open %s, skipping this externalIP: %v", lp.String(), err) + msg := fmt.Sprintf("can't open port %s, skipping it", lp.String()) proxier.recorder.Eventf( &v1.ObjectReference{ @@ -1272,7 +1272,7 @@ func (proxier *Proxier) syncProxyRules() { UID: types.UID(proxier.hostname), Namespace: "", }, v1.EventTypeWarning, err.Error(), msg) - klog.Error(msg) + klog.ErrorS(err, "can't open port, skipping it", "port", lp.String()) continue } klog.V(2).Infof("Opened local port %s", lp.String()) @@ -1466,7 +1466,7 @@ func (proxier *Proxier) syncProxyRules() { } else if svcInfo.Protocol() != v1.ProtocolSCTP { socket, err := proxier.portMapper.OpenLocalPort(&lp) if err != nil { - msg := fmt.Sprintf("can't open %s, skipping this nodePort: %v", lp.String(), err) + msg := fmt.Sprintf("can't open port %s, skipping it", lp.String()) proxier.recorder.Eventf( &v1.ObjectReference{ @@ -1475,7 +1475,7 @@ func (proxier *Proxier) syncProxyRules() { UID: types.UID(proxier.hostname), Namespace: "", }, v1.EventTypeWarning, err.Error(), msg) - klog.Errorf("can't open %s, skipping this nodePort: %v", lp.String(), err) + klog.ErrorS(err, "can't open port, skipping it", "port", lp.String()) continue } klog.V(2).Infof("Opened local port %s", lp.String())