diff options
| author | Lisandro Pin <lisandro.pin@proton.ch> | 2024-12-18 22:26:26 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-12-18 13:26:26 -0800 |
| commit | ba0707af641e41ba3cbed2b533ed2432d21295ba (patch) | |
| tree | 967d95ec034ea3d3adbcea86662be3ab043a40d7 /weed/shell/command_ec_balance.go | |
| parent | 44c48c929ac2e513a3ad5749744c77ab480ae1fe (diff) | |
| download | seaweedfs-ba0707af641e41ba3cbed2b533ed2432d21295ba.tar.xz seaweedfs-ba0707af641e41ba3cbed2b533ed2432d21295ba.zip | |
Allow configuring the maximum number of concurrent tasks for EC parallelization. (#6376)
Follow-up to b0210df0.
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 31782b279..08bbd2a22 100644 --- a/weed/shell/command_ec_balance.go +++ b/weed/shell/command_ec_balance.go @@ -35,7 +35,7 @@ func (c *commandEcBalance) Do(args []string, commandEnv *CommandEnv, writer io.W collection := balanceCommand.String("collection", "EACH_COLLECTION", "collection name, or \"EACH_COLLECTION\" for each collection") dc := balanceCommand.String("dataCenter", "", "only apply the balancing for this dataCenter") shardReplicaPlacement := balanceCommand.String("shardReplicaPlacement", "", "replica placement for EC shards, or master default if empty") - parallelize := balanceCommand.Bool("parallelize", true, "parallelize operations whenever possible") + maxParallelization := balanceCommand.Int("maxParallelization", 10, "run up to X tasks in parallel, whenever possible") applyBalancing := balanceCommand.Bool("force", false, "apply the balancing plan") if err = balanceCommand.Parse(args); err != nil { return nil @@ -62,5 +62,5 @@ func (c *commandEcBalance) Do(args []string, commandEnv *CommandEnv, writer io.W return err } - return EcBalance(commandEnv, collections, *dc, rp, *parallelize, *applyBalancing) + return EcBalance(commandEnv, collections, *dc, rp, *maxParallelization, *applyBalancing) } |