From bb518e6d89e53d28a177ef5a5bc6145cd378213b Mon Sep 17 00:00:00 2001
From: Lyndon-Li <lyonghui@vmware.com>
Date: Mon, 26 Jan 2026 13:58:29 +0800
Subject: [PATCH] replace nodeName with node selector

Signed-off-by: Lyndon-Li <lyonghui@vmware.com>
---
 pkg/exposer/generic_restore.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/pkg/exposer/generic_restore.go b/pkg/exposer/generic_restore.go
index c10370072..57dcf120a 100644
--- a/pkg/exposer/generic_restore.go
+++ b/pkg/exposer/generic_restore.go
@@ -494,12 +494,15 @@ func (e *genericRestoreExposer) createRestorePod(
 	volumeName := string(ownerObject.UID)
 
 	var podAffinity *corev1api.Affinity
+	nodeSelector := map[string]string{}
 	if selectedNode == "" {
 		e.log.Infof("No selected node for restore pod. Try to get affinity from the node-agent config.")
 
 		if affinity != nil {
 			podAffinity = kube.ToSystemAffinity([]*kube.LoadAffinity{affinity})
 		}
+	} else {
+		nodeSelector["kubernetes.io/hostname"] = selectedNode
 	}
 
 	podInfo, err := getInheritedPodInfo(ctx, e.kubeClient, ownerObject.Namespace, nodeOS)
@@ -566,7 +569,6 @@ func (e *genericRestoreExposer) createRestorePod(
 	args = append(args, podInfo.logLevelArgs...)
 
 	var securityCtx *corev1api.PodSecurityContext
-	nodeSelector := map[string]string{}
 	podOS := corev1api.PodOS{}
 	if nodeOS == kube.NodeOSWindows {
 		userID := "ContainerAdministrator"
@@ -656,7 +658,6 @@ func (e *genericRestoreExposer) createRestorePod(
 			ServiceAccountName:            podInfo.serviceAccount,
 			TerminationGracePeriodSeconds: &gracePeriod,
 			Volumes:                       volumes,
-			NodeName:                      selectedNode,
 			RestartPolicy:                 corev1api.RestartPolicyNever,
 			SecurityContext:               securityCtx,
 			Tolerations:                   toleration,