fix: promote failed (#575)

apecloud · Feb 21, 2025 · 66455c0 · 66455c0
1 parent 98f0be6
commit 66455c0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/cmd/cluster/operations.go b/pkg/cmd/cluster/operations.go
@@ -460,7 +460,8 @@ func (o *OperationsOptions) validatePromote(clusterObj *appsv1.Cluster) error {
 
 	getTargetRole := func(roles []appsv1.ReplicaRole) (string, error) {
 		pods, err := o.Client.CoreV1().Pods(clusterObj.Namespace).List(context.Background(), metav1.ListOptions{
-			LabelSelector: fmt.Sprintf("%s=%s", constant.KBAppComponentLabelKey, podObj.Labels[constant.KBAppComponentLabelKey]),
+			LabelSelector: fmt.Sprintf("%s=%s,%s=%s", constant.KBAppComponentLabelKey,
+				podObj.Labels[constant.KBAppComponentLabelKey], constant.AppInstanceLabelKey, clusterObj.Name),
 		})
 		if err != nil {
 			return "", err