diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2017-03-03 20:02:56 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-03-03 20:02:56 -0800 |
| commit | 470d95091819edf8eef2f5b3f28fef6b8761c4ef (patch) | |
| tree | 4f47b3496b8387a3557d710f4bf1f7b7b13fc479 | |
| parent | 30f138a538c71fe9427ecf49b906a7d73632a779 (diff) | |
| parent | 4049c72e6cffb199c7bd3b80cc5f9429560ba133 (diff) | |
| download | seaweedfs-470d95091819edf8eef2f5b3f28fef6b8761c4ef.tar.xz seaweedfs-470d95091819edf8eef2f5b3f28fef6b8761c4ef.zip | |
Merge pull request #461 from sparklxb/master
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(), |