diff options
| author | sparklxb <sparklxb@163.com> | 2017-03-04 11:24:03 +0800 |
|---|---|---|
| committer | sparklxb <sparklxb@163.com> | 2017-03-04 11:24:12 +0800 |
| commit | 4049c72e6cffb199c7bd3b80cc5f9429560ba133 (patch) | |
| tree | 4f47b3496b8387a3557d710f4bf1f7b7b13fc479 | |
| parent | 30f138a538c71fe9427ecf49b906a7d73632a779 (diff) | |
| download | seaweedfs-4049c72e6cffb199c7bd3b80cc5f9429560ba133.tar.xz seaweedfs-4049c72e6cffb199c7bd3b80cc5f9429560ba133.zip | |
fix bug: replication, metadata not replicated
| -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(), |