diff --git a/node/pod.go b/node/pod.go index 380c705ab..aea18951a 100644 --- a/node/pod.go +++ b/node/pod.go @@ -213,6 +213,10 @@ func (pc *PodController) enqueuePodStatusUpdate(ctx context.Context, q workqueue if obj, ok := pc.knownPods.Load(key); ok { kpod := obj.(*knownPod) kpod.Lock() + if cmp.Equal(kpod.lastPodStatusReceivedFromProvider, pod) { + kpod.Unlock() + return + } kpod.lastPodStatusReceivedFromProvider = pod kpod.Unlock() q.AddRateLimited(key)