aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_volume_balance.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-03-14 21:29:55 -0700
committerChris Lu <chris.lu@gmail.com>2021-03-14 21:29:55 -0700
commita4cfffc264d3af61a3e363dc4d9db8f606284069 (patch)
tree7ae6a36e94ae071dd815d7194169ca43f884cb02 /weed/shell/command_volume_balance.go
parentca100568f76b9ccc472352c62bc1647c9d156843 (diff)
downloadseaweedfs-a4cfffc264d3af61a3e363dc4d9db8f606284069.tar.xz
seaweedfs-a4cfffc264d3af61a3e363dc4d9db8f606284069.zip
shell: fix moving volume, volume server evacuate
fix https://github.com/chrislusf/seaweedfs/issues/1534
Diffstat (limited to 'weed/shell/command_volume_balance.go')
-rw-r--r--weed/shell/command_volume_balance.go5
1 files changed, 2 insertions, 3 deletions
diff --git a/weed/shell/command_volume_balance.go b/weed/shell/command_volume_balance.go
index e0c41f310..ad7da0e44 100644
--- a/weed/shell/command_volume_balance.go
+++ b/weed/shell/command_volume_balance.go
@@ -393,9 +393,8 @@ func adjustAfterMove(v *master_pb.VolumeInformationMessage, volumeReplicas map[u
if replica.location.dataNode.Id == fullNode.info.Id &&
replica.location.rack == fullNode.rack &&
replica.location.dc == fullNode.dc {
- replica.location.dc = emptyNode.dc
- replica.location.rack = emptyNode.rack
- replica.location.dataNode = emptyNode.info
+ loc := newLocation(emptyNode.dc, emptyNode.rack, emptyNode.info)
+ replica.location = &loc
return
}
}