diff --git a/weed/topology/store_replicate.go b/weed/topology/store_replicate.go
index aa312ac03..d7fb501c0 100644
--- a/weed/topology/store_replicate.go
+++ b/weed/topology/store_replicate.go
@@ -58,10 +58,14 @@ func ReplicatedWrite(masterNode string, s *storage.Store,
 
 				pairMap := make(map[string]string)
 				if needle.HasPairs() {
-					err := json.Unmarshal(needle.Pairs, &pairMap)
+					tmpMap := make(map[string]string)
+					err := json.Unmarshal(needle.Pairs, &tmpMap)
 					if err != nil {
 						glog.V(0).Infoln("Unmarshal pairs error:", err)
 					}
+					for k, v := range tmpMap {
+						pairMap[storage.PairNamePrefix+k] = v
+					}
 				}
 
 				_, err := operation.Upload(u.String(),