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

feat(master): Skip the discard dp periodic check. #23132815

Browse Source 
Signed-off-by: zhumingze <zhumingze@oppo.com>
This commit is contained in:
zhumingze 2025-03-20 15:06:00 +08:00 committed by zhumingze1108
parent b7759e42c5
commit 487641d0f9
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
master/data_partition_check.go
View File

@ -170,7 +170,7 @@ func (partition *DataPartition) checkMissingReplicas(clusterID, leaderAddr strin
WarnMetrics.dpMissingReplicaMutex.Unlock()
for _, replica := range partition.Replicas {
if partition.hasHost(replica.Addr) && replica.isMissing(dataPartitionMissSec) && !partition.IsDiscard {
if partition.hasHost(replica.Addr) && replica.isMissing(dataPartitionMissSec) {
if partition.needToAlarmMissingDataPartition(replica.Addr, dataPartitionWarnInterval) {
dataNode := replica.getReplicaNode()
var lastReportTime time.Time
@ -219,7 +219,7 @@ func (partition *DataPartition) checkMissingReplicas(clusterID, leaderAddr strin
}
for _, addr := range partition.Hosts {
if partition.hasMissingDataPartition(addr) && partition.needToAlarmMissingDataPartition(addr, dataPartitionWarnInterval) && !partition.IsDiscard {
if partition.hasMissingDataPartition(addr) && partition.needToAlarmMissingDataPartition(addr, dataPartitionWarnInterval) {
msg := fmt.Sprintf("action[checkMissErr],clusterID[%v] partitionID:%v on node:%v "+
"miss time > :%v but server not exsit So Migrate", clusterID, partition.PartitionID, addr, dataPartitionMissSec)
msg = msg + fmt.Sprintf(" decommissionDataPartitionURL is http://%v/dataPartition/decommission?id=%v&addr=%v", leaderAddr, partition.PartitionID, addr)

4
master/vol.go
View File

@ -763,6 +763,10 @@ func (vol *Vol) checkDataPartitions(c *Cluster) (cnt int) {
}()
for _, dp := range partitions {
if dp.IsDiscard {
continue
}
statByMedia[dp.MediaType] += dp.getMaxUsedSpace()
if proto.IsPreLoadDp(dp.PartitionType) {