From 1470c10d30aea08f44b16733bdce5b9c27083536 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E7=A5=96=E5=BB=BA?= Date: Wed, 15 Mar 2023 10:31:10 +0800 Subject: [PATCH] add node to addNodeQueue if required annations are missing (#2481) --- pkg/controller/node.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/pkg/controller/node.go b/pkg/controller/node.go index a9de6605cbd..831f7832d35 100644 --- a/pkg/controller/node.go +++ b/pkg/controller/node.go @@ -59,8 +59,13 @@ func (c *Controller) enqueueUpdateNode(oldObj, newObj interface{}) { utilruntime.HandleError(err) return } - klog.V(3).Infof("enqueue update node %s", key) - c.updateNodeQueue.Add(key) + if len(newNode.Annotations) == 0 || newNode.Annotations[util.AllocatedAnnotation] != "true" { + klog.V(3).Infof("enqueue add node %s", key) + c.addNodeQueue.Add(key) + } else { + klog.V(3).Infof("enqueue update node %s", key) + c.updateNodeQueue.Add(key) + } } }