modify lb-svc dnat port error (#2927)

hongzhen-ma · hongzhen-ma · commit 94859807c310 · 2023-06-13T10:43:25.000+08:00
diff --git a/pkg/controller/service_lb.go b/pkg/controller/service_lb.go
@@ -321,7 +321,7 @@ func (c *Controller) updatePodAttachNets(pod *corev1.Pod, svc *corev1.Service) e
 		}
 
 		var rules []string
-		rules = append(rules, fmt.Sprintf("%s,%d,%s,%s,%d,%s", loadBalancerIP, port.Port, protocol, svc.Spec.ClusterIP, port.TargetPort.IntVal, defaultGateway))
+		rules = append(rules, fmt.Sprintf("%s,%d,%s,%s,%d,%s", loadBalancerIP, port.Port, protocol, svc.Spec.ClusterIP, port.Port, defaultGateway))
 		klog.Infof("add dnat rules for lb svc pod, %v", rules)
 		if err := c.execNatRules(pod, POD_DNAT_ADD, rules); err != nil {
 			klog.Errorf("failed to add dnat for pod, err: %v", err)

Original file line number	Diff line number	Diff line change
`@@ -321,7 +321,7 @@ func (c Controller) updatePodAttachNets(pod corev1.Pod, svc *corev1.Service) e`
`321`	`321`	`}`
`322`	`322`
`323`	`323`	`var rules []string`
`324`		`- rules = append(rules, fmt.Sprintf("%s,%d,%s,%s,%d,%s", loadBalancerIP, port.Port, protocol, svc.Spec.ClusterIP, port.TargetPort.IntVal, defaultGateway))`
	`324`	`+ rules = append(rules, fmt.Sprintf("%s,%d,%s,%s,%d,%s", loadBalancerIP, port.Port, protocol, svc.Spec.ClusterIP, port.Port, defaultGateway))`
`325`	`325`	`klog.Infof("add dnat rules for lb svc pod, %v", rules)`
`326`	`326`	`if err := c.execNatRules(pod, POD_DNAT_ADD, rules); err != nil {`
`327`	`327`	`klog.Errorf("failed to add dnat for pod, err: %v", err)`