gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(master): fix the bug that add learner plan's overload is null.#1000578895

Browse Source 
Signed-off-by: Wu Huocheng <wuhuocheng@oppo.com>
This commit is contained in:
Wu Huocheng 2025-12-26 15:44:05 +08:00
parent 7ea467d7cb
commit 664f2a9586
1 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
master/cluster_balance.go
View File

@ -1235,6 +1235,27 @@ func (c *Cluster) UpdateMigrateDestination(migratePlan *proto.ClusterPlan, mpPla
return err
}
if migratePlan.Type == AddLearner {
param := &MetaPartitionPlanUserParams{
Mode: migratePlan.Mode,
Count: migratePlan.ModeCnt,
StartID: migratePlan.StartId,
EndID: migratePlan.EndId,
SelectType: migratePlan.SelectType,
ZoneName: migratePlan.ZoneName,
NodeSetID: migratePlan.NodeSetID,
SelectTag: migratePlan.SelectTag,
AutoPromoteLearner: migratePlan.AutoPromote,
}
err = c.AddLearnerToDestination(migratePlan, mpPlan, param)
if err != nil {
log.LogErrorf("AddLearnerToDestination error: %s", err.Error())
return err
}
return nil
}
// renew the planed destination meta node.
if mpPlan.CrossZone {
err = FindMigrateDestRetainZone(migratePlan, mpPlan)