fix(master): No longer allow single replica dp raftForce deletion. #23115830

Signed-off-by: zhumingze <zhumingze@oppo.com>
This commit is contained in:
zhumingze 2025-03-06 16:28:29 +08:00 committed by zhumingze1108
parent 3c91dcbf84
commit fe8906f897

View File

@ -1422,6 +1422,13 @@ func (partition *DataPartition) Decommission(c *Cluster) bool {
goto errHandler
}
if partition.ReplicaNum == 1 && partition.DecommissionRaftForce {
log.LogWarnf("action[decommissionDataPartition] dp [%v] single replica does not support raftForce deletion", partition.decommissionInfo())
partition.DecommissionErrorMessage = "single replica does not support raftForce deletion"
partition.markRollbackFailed(false)
return false
}
partition.SetDecommissionStatus(DecommissionPrepare)
err = c.syncUpdateDataPartition(partition)
if err != nil {