mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2025-09-19 03:39:22 +08:00
volume.tier.move: avoid data loss when destination volume server already has the volume
fix https://github.com/chrislusf/seaweedfs/issues/2001
This commit is contained in:
@@ -133,7 +133,7 @@ func doVolumeTierMove(commandEnv *CommandEnv, writer io.Writer, collection strin
|
|||||||
|
|
||||||
// remove the remaining replicas
|
// remove the remaining replicas
|
||||||
for _, loc := range locations {
|
for _, loc := range locations {
|
||||||
if loc.Url != sourceVolumeServer {
|
if loc.Url != dst.dataNode.Id {
|
||||||
if err = deleteVolume(commandEnv.option.GrpcDialOption, vid, loc.Url); err != nil {
|
if err = deleteVolume(commandEnv.option.GrpcDialOption, vid, loc.Url); err != nil {
|
||||||
fmt.Fprintf(writer, "failed to delete volume %d on %s\n", vid, loc.Url)
|
fmt.Fprintf(writer, "failed to delete volume %d on %s\n", vid, loc.Url)
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user