diff --git a/prog/weave-npc/main.go b/prog/weave-npc/main.go index ea164d4a..44c65a37 100644 --- a/prog/weave-npc/main.go +++ b/prog/weave-npc/main.go @@ -186,6 +186,17 @@ func createBaseRules(ipt *iptables.IPTables, ips ipset.Interface) error { return err } + // delete `weave-local-pods` ipset which is no longer used by weave-npc + weaveLocalPodExist, err := ipsetExist(ips, npc.LocalIpset) + if err != nil { + common.Log.Errorf("Failed to destroy ipset '%s'", npc.LocalIpset) + } else if weaveLocalPodExist { + common.Log.Debugf("Destroying ipset '%s'", npc.LocalIpset) + if err := ips.Destroy(npc.LocalIpset); err != nil { + common.Log.Errorf("Failed to destroy ipset '%s'", npc.LocalIpset) + } + } + return nil }