aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_volume_tier_upload.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-08-13 03:09:28 -0700
committerChris Lu <chris.lu@gmail.com>2021-08-13 03:09:28 -0700
commit0f7d4556d839ffc9d0dcfbc965e3b970cb30c77d (patch)
treec91a04437e24626b00dc1f0e0de0efdd92f910ff /weed/shell/command_volume_tier_upload.go
parent333cdce485ee5389306527cc8c1b40fdcf884137 (diff)
downloadseaweedfs-0f7d4556d839ffc9d0dcfbc965e3b970cb30c77d.tar.xz
seaweedfs-0f7d4556d839ffc9d0dcfbc965e3b970cb30c77d.zip
shell: volume.tier.move makes up changes if volume move failed
Diffstat (limited to 'weed/shell/command_volume_tier_upload.go')
-rw-r--r--weed/shell/command_volume_tier_upload.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/shell/command_volume_tier_upload.go b/weed/shell/command_volume_tier_upload.go
index f92cdc3e4..c8540a7dc 100644
--- a/weed/shell/command_volume_tier_upload.go
+++ b/weed/shell/command_volume_tier_upload.go
@@ -101,7 +101,7 @@ func doVolumeTierUpload(commandEnv *CommandEnv, writer io.Writer, collection str
return fmt.Errorf("volume %d not found", vid)
}
- err = markVolumeReadonly(commandEnv.option.GrpcDialOption, needle.VolumeId(vid), locations)
+ err = markVolumeReplicasWritable(commandEnv.option.GrpcDialOption, needle.VolumeId(vid), locations, false)
if err != nil {
return fmt.Errorf("mark volume %d as readonly on %s: %v", vid, locations[0].Url, err)
}