diff --git a/sdk/data/wrapper/wrapper.go b/sdk/data/wrapper/wrapper.go
index f4c3b126d..8b1161a54 100644
--- a/sdk/data/wrapper/wrapper.go
+++ b/sdk/data/wrapper/wrapper.go
@@ -562,7 +562,7 @@ func (w *Wrapper) replaceOrInsertPartition(dp *DataPartition) {
 		old.ReplicaNum = dp.ReplicaNum
 		old.Hosts = dp.Hosts
 		old.IsDiscard = dp.IsDiscard
-		old.NearHosts = dp.Hosts
+		old.NearHosts = dp.NearHosts
 
 		dp.Metrics = old.Metrics
 	} else {