fix: filter k8s node update event to avoid bcs-k8s-watch queue stuck.…

… issue TencentBlueKing#220

bcs-k8s/bcs-k8s-watch/app/k8s/watcher.go

@@ -164,6 +164,7 @@ func (watcher *Watcher) UpdateEvent(oldObj, newObj interface{}) {
 	//    if newTgwIngress.ResourceVersion == oldTgwIngress.ResourceVersion {
 	//        return
 	//}
+
 	if reflect.DeepEqual(oldObj, d) {
 		dMeta := d.(metav1.Object)
 		namespace := dMeta.GetNamespace()
@@ -173,6 +174,30 @@ func (watcher *Watcher) UpdateEvent(oldObj, newObj interface{}) {
 		return
 	}
 
+	// skip unnecessary node update event, to avoid writer queue stuck
+	if watcher.resourceType == "Node" {
+		oldNode := oldObj.(*v1.Node)
+		newNode := newObj.(*v1.Node)
+
+		var tempLastTimes = make([]metav1.Time, 5)
+		tempVersion := newNode.ResourceVersion
+		newNode.ResourceVersion = oldNode.ResourceVersion
+		for i := range newNode.Status.Conditions {
+			tempLastTimes[i] = newNode.Status.Conditions[i].LastHeartbeatTime
+			newNode.Status.Conditions[i].LastHeartbeatTime = oldNode.Status.Conditions[i].LastHeartbeatTime
+		}
+
+		if reflect.DeepEqual(oldNode, newNode) {
+			glog.V(2).Infof("skip unnecessary node update event")
+			return
+		}
+
+		newNode.ResourceVersion = tempVersion
+		for i := range newNode.Status.Conditions {
+			newNode.Status.Conditions[i].LastHeartbeatTime = tempLastTimes[i]
+		}
+	}
+
 	syncData := watcher.genSyncData(newObj, "Update")
 	if syncData == nil {
 		return