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): dp is decommissioned by raftForce, disk manager check recovery for new replica

Browse Source 
close:#21938887

Signed-off-by: chihe <chihe@oppo.com>
This commit is contained in:
chihe 2024-05-10 14:43:06 +08:00 committed by AmazingChi
parent ff8b40abae
commit cab9ec44f3
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
master/disk_manager.go
View File

@ -71,6 +71,8 @@ func (c *Cluster) checkDiskRecoveryProgress() {
c.Name, partitionID, partition.VolName))
continue
}
log.LogInfof("action[checkDiskRecoveryProgress] dp %v isSpec %v replicas %v conf replicas num %v status(%v)",
partition.PartitionID, partition.isSpecialReplicaCnt(), len(partition.Replicas), int(partition.ReplicaNum), partition.GetDecommissionStatus())
log.LogInfof("action[checkDiskRecoveryProgress] dp %v isSpec %v replicas %v conf replicas num %v status(%v)",
partition.PartitionID, partition.isSpecialReplicaCnt(), len(partition.Replicas), int(partition.ReplicaNum), partition.GetDecommissionStatus())
if len(partition.Replicas) == 0 {