From 8f718520bd0b2f4e3264d6f67fcb70260af1ede4 Mon Sep 17 00:00:00 2001 From: wayblink Date: Tue, 2 Jul 2024 15:42:59 +0800 Subject: [PATCH] fix: remove isFull check in compaction.enqueue Signed-off-by: wayblink --- internal/datacoord/compaction.go | 3 --- 1 file changed, 3 deletions(-) diff --git a/internal/datacoord/compaction.go b/internal/datacoord/compaction.go index 145849bec3c0..20ea91811d79 100644 --- a/internal/datacoord/compaction.go +++ b/internal/datacoord/compaction.go @@ -534,9 +534,6 @@ func (c *compactionPlanHandler) getCompactionTask(planID int64) CompactionTask { func (c *compactionPlanHandler) enqueueCompaction(task *datapb.CompactionTask) error { log := log.With(zap.Int64("planID", task.GetPlanID()), zap.Int64("triggerID", task.GetTriggerID()), zap.Int64("collectionID", task.GetCollectionID()), zap.String("type", task.GetType().String())) - if c.isFull() { - return errCompactionBusy - } t, err := c.createCompactTask(task) if err != nil { return err