diff --git a/pkg/controller/network/nsnetworkpolicy/controller.go b/pkg/controller/network/nsnetworkpolicy/controller.go index 66307443c76f397a7c0198b0b78bae62b71e8ec1..f38e82432a1a491d414f7da94c71e0093e3d5eb0 100644 --- a/pkg/controller/network/nsnetworkpolicy/controller.go +++ b/pkg/controller/network/nsnetworkpolicy/controller.go @@ -462,8 +462,10 @@ func (c *NSNetworkPolicyController) syncNs(key string) error { if err != nil { return err } + if len(ruleNode.From) > 0 { + policy.Spec.Ingress = append(policy.Spec.Ingress, ruleNode) + } - policy.Spec.Ingress = append(policy.Spec.Ingress, ruleNode) if delete { c.provider.Delete(c.provider.GetKey(AnnotationNPNAME, ns.Name)) } else { @@ -531,7 +533,7 @@ func (c *NSNetworkPolicyController) syncNSNP(key string) error { if err != nil { if errors.IsNotFound(err) { klog.V(4).Infof("NSNP %v has been deleted", key) - c.provider.Delete(c.provider.GetKey(name, namespace)) + c.provider.Delete(c.provider.GetKey(network.NSNPPrefix+name, namespace)) return nil }