diff --git a/datanode/data_partition_repair.go b/datanode/data_partition_repair.go index 505ce0663..69c710d7f 100644 --- a/datanode/data_partition_repair.go +++ b/datanode/data_partition_repair.go @@ -157,6 +157,10 @@ func (dp *DataPartition) repair(extentType uint8) { } func (dp *DataPartition) buildDataPartitionRepairTask(repairTasks []*DataPartitionRepairTask, extentType uint8, tinyExtents []uint64, replica []string) (err error) { + if len(repairTasks) == 0 { + return fmt.Errorf("dp replica is empty. dp %d, replicas %v", dp.partitionID, dp.replicas) + } + // get the local extent info extents, leaderTinyDeleteRecordFileSize, err := dp.getLocalExtentInfo(extentType, tinyExtents) if err != nil {