Merge pull request kosmos-io#341 from OrangeBao/release-0.2.0

fix: resolve the issue of node address update errors

Author: wuyingjun-lucky

Diff for: pkg/clustertree/cluster-manager/controllers/node_resources_controller.go

@@ -149,11 +149,6 @@ func (c *NodeResourcesController) Reconcile(ctx context.Context, request reconci
 				// }
 				clone.Spec.Taints = rootNode.Spec.Taints
 				clone.Status = node.Status
-				clone.Status.Addresses, err = leafUtils.GetAddress(ctx, c.RootClientset, node.Status.Addresses)
-				if err != nil {
-					klog.Errorf("GetAddress node %s, err: %v, ", rootNode.Name, err)
-					return reconcile.Result{}, err
-				}
 			}
 		}
 

Diff for: pkg/clustertree/cluster-manager/utils/leaf_model_handler.go

@@ -109,7 +109,7 @@ func (h AggregationModelHandler) UpdateNodeStatus(ctx context.Context, n []*core
 			return fmt.Errorf("cannot get node in leaf cluster while update node status, leaf node item is 0")
 		}
 
-		clone.Status.Addresses, err = GetAddress(ctx, h.RootClientset, nodeListInLeaf.Items[0].Status.Addresses)
+		updateAddress, err := GetAddress(ctx, h.RootClientset, nodeListInLeaf.Items[0].Status.Addresses)
 
 		if err != nil {
 			return err
@@ -121,8 +121,14 @@ func (h AggregationModelHandler) UpdateNodeStatus(ctx context.Context, n []*core
 			return fmt.Errorf("cannot get node while update node status %s, err: %v", node.Name, err)
 		}
 
-		if node, err = h.RootClientset.CoreV1().Nodes().PatchStatus(ctx, node.Name, patch); err != nil {
+		if latestNode, err := h.RootClientset.CoreV1().Nodes().PatchStatus(ctx, node.Name, patch); err != nil {
 			return err
+		} else {
+			latestNode.ResourceVersion = ""
+			latestNode.Status.Addresses = updateAddress
+			if _, err = h.RootClientset.CoreV1().Nodes().UpdateStatus(ctx, latestNode, metav1.UpdateOptions{}); err != nil {
+				return err
+			}
 		}
 		return nil
 	})

Diff for: pkg/clustertree/cluster-manager/utils/rootcluster.go

@@ -49,7 +49,10 @@ func GetAddress(ctx context.Context, rootClient kubernetes.Interface, originAddr
 }
 
 func SortAddress(ctx context.Context, rootClient kubernetes.Interface, originAddress []corev1.NodeAddress) ([]corev1.NodeAddress, error) {
-	rootnodes, err := rootClient.CoreV1().Nodes().List(ctx, metav1.ListOptions{})
+	rootnodes, err := rootClient.CoreV1().Nodes().List(ctx, metav1.ListOptions{
+		// get the node which is not created by kosmos
+		LabelSelector: fmt.Sprintf("%s!=%s", utils.KosmosNodeLabel, utils.KosmosNodeValue),
+	})
 	if err != nil {
 		return nil, fmt.Errorf("create node failed, cannot get node from root cluster, err: %v", err)
 	}