diff --git a/datanode/data_partition_repair.go b/datanode/data_partition_repair.go index d27888806..2397572af 100644 --- a/datanode/data_partition_repair.go +++ b/datanode/data_partition_repair.go @@ -149,6 +149,7 @@ func (dp *DataPartition) repair(extentType uint8) { // every time we need to figure out which extents need to be repaired and which ones do not. dp.sendAllTinyExtentsToC(extentType, availableTinyExtents, brokenTinyExtents) + dp.isMissingTinyExtent = false // error check if dp.extentStore.AvailableTinyExtentCnt()+dp.extentStore.BrokenTinyExtentCnt() != storage.TinyExtentCount { dp.isMissingTinyExtent = true diff --git a/master/data_partition.go b/master/data_partition.go index 513118520..93f8dec27 100644 --- a/master/data_partition.go +++ b/master/data_partition.go @@ -1090,7 +1090,7 @@ const InvalidDecommissionDpCnt = -1 const ( defaultDecommissionParallelLimit = 10 defaultDecommissionRetryLimit = 5 - defaultDecommissionRetryInternal = 10 * time.Minute + defaultDecommissionRetryInternal = 5 * time.Minute defaultDecommissionRollbackLimit = 3 defaultSetRestoreReplicaStatusLimit = 300 defaultDecommissionFirstHostDiskParallelLimit = 10