fix(master): dp with sepcical replicum delete raft failed, don't reset decommission src

close:#22054632

Signed-off-by: chihe <chihe@oppo.com>
This commit is contained in:
chihe 2024-04-09 09:17:08 +08:00 committed by AmazingChi
parent 23421c97e2
commit 2832f093f9

View File

@ -1381,6 +1381,10 @@ func (partition *DataPartition) Decommission(c *Cluster) bool {
}
errHandler:
// choose other node to create data partition
if resetDecommissionDst {
partition.DecommissionDstAddr = ""
}
// special replica num receive stop signal,donot reset SingleDecommissionStatus for decommission again
if partition.GetDecommissionStatus() == DecommissionPause {
log.LogWarnf("action[decommissionDataPartition] partitionID:%v is stopped", partition.PartitionID)