enhance: speed up loading with many deletions (milvus-io#29455)

the executor always fetches the latest segment info, so we could consume from the latest checkpoint, which could save much time while deleted many entities Signed-off-by: yah01 <[email protected]>
bigsheeper · Dec 25, 2023 · 1d6bcd1 · 1d6bcd1
1 parent ae180d1
commit 1d6bcd1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/querycoordv2/task/executor.go b/internal/querycoordv2/task/executor.go
@@ -194,9 +194,9 @@ func (ex *Executor) loadSegment(task *SegmentTask, step int) error {
 		indexes = nil
 	}
 
-	channel := ex.targetMgr.GetDmChannel(task.CollectionID(), segment.GetInsertChannel(), meta.CurrentTarget)
+	channel := ex.targetMgr.GetDmChannel(task.CollectionID(), segment.GetInsertChannel(), meta.NextTarget)
 	if channel == nil {
-		channel = ex.targetMgr.GetDmChannel(task.CollectionID(), segment.GetInsertChannel(), meta.NextTarget)
+		channel = ex.targetMgr.GetDmChannel(task.CollectionID(), segment.GetInsertChannel(), meta.CurrentTarget)
 	}
 
 	// Get collection index info