diff --git a/pkg/cmd/cluster/operations.go b/pkg/cmd/cluster/operations.go index a898310e4..b7f708df7 100755 --- 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