aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_volume_delete_empty.go
diff options
context:
space:
mode:
authorKonstantin Lebedev <9497591+kmlebedev@users.noreply.github.com>2023-06-12 22:42:44 +0500
committerGitHub <noreply@github.com>2023-06-12 10:42:44 -0700
commit25535e9c36ad55b4e75f88ed01ca0c5e3947663e (patch)
tree8e6e71e734468822cabc2bbf979d7d6cff67f68f /weed/shell/command_volume_delete_empty.go
parent2e42cdeb221572a20b0d6576dc8e2f6f3369b546 (diff)
downloadseaweedfs-25535e9c36ad55b4e75f88ed01ca0c5e3947663e.tar.xz
seaweedfs-25535e9c36ad55b4e75f88ed01ca0c5e3947663e.zip
Delete volume is empty (#4561)
* use onlyEmpty for deleteVolume https://github.com/seaweedfs/seaweedfs/issues/4559 * fix IsEmpty * fix test --------- Co-authored-by: Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.co>
Diffstat (limited to 'weed/shell/command_volume_delete_empty.go')
-rw-r--r--weed/shell/command_volume_delete_empty.go3
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/shell/command_volume_delete_empty.go b/weed/shell/command_volume_delete_empty.go
index 4f4e5079d..f02cf87d9 100644
--- a/weed/shell/command_volume_delete_empty.go
+++ b/weed/shell/command_volume_delete_empty.go
@@ -60,7 +60,8 @@ func (c *commandVolumeDeleteEmpty) Do(args []string, commandEnv *CommandEnv, wri
if v.Size <= 8 && v.ModifiedAtSecond > 0 && v.ModifiedAtSecond+quietSeconds < nowUnixSeconds {
if *applyBalancing {
log.Printf("deleting empty volume %d from %s", v.Id, dn.Id)
- if deleteErr := deleteVolume(commandEnv.option.GrpcDialOption, needle.VolumeId(v.Id), pb.NewServerAddressFromDataNode(dn)); deleteErr != nil {
+ if deleteErr := deleteVolume(commandEnv.option.GrpcDialOption, needle.VolumeId(v.Id),
+ pb.NewServerAddressFromDataNode(dn), true); deleteErr != nil {
err = deleteErr
}
continue