diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2022-05-16 01:17:53 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-05-16 01:17:53 -0700 |
| commit | 17c676cb86a5e9a7d2b9c8c6b1970c0350406fd0 (patch) | |
| tree | 8dde9def848188b8f1bdd230c2f082c5267dccdd | |
| parent | ca85b665115cebc062ebfd6d081101bcc9e757b3 (diff) | |
| parent | 10d435f2c25658b16562adad975d81a71650b61d (diff) | |
| download | seaweedfs-17c676cb86a5e9a7d2b9c8c6b1970c0350406fd0.tar.xz seaweedfs-17c676cb86a5e9a7d2b9c8c6b1970c0350406fd0.zip | |
Merge pull request #3056 from kmlebedev/avoid_del_volume
avoid delete volume replica if collection mismatch
| -rw-r--r-- | weed/shell/command_volume_fix_replication.go | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/weed/shell/command_volume_fix_replication.go b/weed/shell/command_volume_fix_replication.go index c4bef5925..3c5538550 100644 --- a/weed/shell/command_volume_fix_replication.go +++ b/weed/shell/command_volume_fix_replication.go @@ -200,6 +200,17 @@ func (c *commandVolumeFixReplication) deleteOneVolume(commandEnv *CommandEnv, wr } } + сollectionIsMismatch := false + for _, volumeReplica := range replicas { + if volumeReplica.info.Collection != replica.info.Collection { + fmt.Fprintf(writer, "skip delete volume %d as collection %s is mismatch: %s\n", replica.info.Id, replica.info.Collection, volumeReplica.info.Collection) + сollectionIsMismatch = true + } + } + if сollectionIsMismatch { + continue + } + fmt.Fprintf(writer, "deleting volume %d from %s ...\n", replica.info.Id, replica.location.dataNode.Id) if !takeAction { |