diff options
| -rw-r--r-- | weed/topology/store_replicate.go | 6 |
1 files changed, 5 insertions, 1 deletions
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(), |