From 30e31c045118310c110249a8de80a44090e1e2cc Mon Sep 17 00:00:00 2001 From: wadecai Date: Mon, 16 Mar 2020 17:33:36 +0800 Subject: [PATCH] Check pod status equal before enqueue --- node/pod.go | 4 ++++ 1 file changed, 4 insertions(+) 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)