fix: Check whether compaction plan exist before update (#28826)

Fix: #28825 Signed-off-by: Congqi Xia <[email protected]>
milvus-io · Nov 29, 2023 · 3f9da2b · 3f9da2b
1 parent 3b1b14d
commit 3f9da2b
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/internal/datacoord/compaction.go b/internal/datacoord/compaction.go
@@ -197,7 +197,11 @@ func (c *compactionPlanHandler) removeTasksByChannel(channel string) {
 func (c *compactionPlanHandler) updateTask(planID int64, opts ...compactionTaskOpt) {
 	c.mu.Lock()
 	defer c.mu.Unlock()
-	c.plans[planID] = c.plans[planID].shadowClone(opts...)
+	plan, ok := c.plans[planID]
+	if !ok {
+		return
+	}
+	c.plans[planID] = plan.shadowClone(opts...)
 }
 
 func (c *compactionPlanHandler) enqueuePlan(signal *compactionSignal, plan *datapb.CompactionPlan) error {