[horus] fixed drain fieldSelector

apache · Sep 29, 2024 · bced931 · bced931
1 parent 15c6627
commit bced931
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/app/horus/core/horuser/node_drain.go b/app/horus/core/horuser/node_drain.go
@@ -33,7 +33,7 @@ func (h *Horuser) Drain(nodeName, clusterName string) (err error) {
 
 	ctxFirst, cancelFirst := h.GetK8sContext()
 	defer cancelFirst()
-	listOpts := v1.ListOptions{FieldSelector: fmt.Sprintf("nodeName=%s", nodeName)}
+	listOpts := v1.ListOptions{FieldSelector: fmt.Sprintf("spec.nodeName=%s", nodeName)}
 	var podNamespace string
 	pod, err := kubeClient.CoreV1().Pods(podNamespace).List(ctxFirst, listOpts)
 	if err != nil {