diff options
| author | Lisandro Pin <lisandro.pin@proton.ch> | 2024-12-06 18:00:06 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-12-06 09:00:06 -0800 |
| commit | 522a25790a27de702d4801aa4969880c2a782e55 (patch) | |
| tree | ae0556315e0ffd9058190a32476cf0c95ddf68b5 /weed/shell/command_ec_balance.go | |
| parent | 914ff0e7189390690d2681f72567c9cc5c4ddd05 (diff) | |
| download | seaweedfs-522a25790a27de702d4801aa4969880c2a782e55.tar.xz seaweedfs-522a25790a27de702d4801aa4969880c2a782e55.zip | |
Remove average constraints when selecting nodes/racks to balance EC shards into. (#6325)
Diffstat (limited to 'weed/shell/command_ec_balance.go')
| -rw-r--r-- | weed/shell/command_ec_balance.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/shell/command_ec_balance.go b/weed/shell/command_ec_balance.go index 043c70366..81d214fcc 100644 --- a/weed/shell/command_ec_balance.go +++ b/weed/shell/command_ec_balance.go @@ -50,7 +50,7 @@ func (c *commandEcBalance) Help() string { averageShardsPerEcRack = totalShardNumber / numRacks // totalShardNumber is 14 for now, later could varies for each dc ecShardsToMove = select overflown ec shards from racks with ec shard counts > averageShardsPerEcRack for each ecShardsToMove { - destRack = pickOneRack(rack~shardCount, rack~volumeIdShardCount, averageShardsPerEcRack, ecShardReplicaPlacement) + destRack = pickOneRack(rack~shardCount, rack~volumeIdShardCount, ecShardReplicaPlacement) destVolumeServers = volume servers on the destRack pickOneEcNodeAndMoveOneShard(destVolumeServers) } @@ -69,7 +69,7 @@ func (c *commandEcBalance) Help() string { volumeServersOverAverage = volume servers with volumeId's ec shard counts > averageShardsPerEcRack ecShardsToMove = select overflown ec shards from volumeServersOverAverage for each ecShardsToMove { - destVolumeServer = pickOneVolumeServer(volumeServer~shardCount, volumeServer~volumeIdShardCount, averageShardCount, ecShardReplicaPlacement) + destVolumeServer = pickOneVolumeServer(volumeServer~shardCount, volumeServer~volumeIdShardCount, ecShardReplicaPlacement) pickOneEcNodeAndMoveOneShard(destVolumeServers) } } |