Fix: Miss channel info when load growing segment (#17789) (#17797)

Signed-off-by: Nzhagnlu <lu.zhang@zilliz.com>
Co-authored-by: Nzhagnlu <lu.zhang@zilliz.com>
Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com>
Co-authored-by: Nzhagnlu <1542303831@qq.com>
Co-authored-by: Nzhagnlu <lu.zhang@zilliz.com>

internal/querynode/segment_loader.go

@@ -120,6 +120,7 @@ func (loader *segmentLoader) LoadSegment(req *querypb.LoadSegmentsRequest, segme
 		segmentID := info.SegmentID
 		partitionID := info.PartitionID
 		collectionID := info.CollectionID
+		vChannelID := info.InsertChannel
 
 		collection, err := loader.metaReplica.getCollectionByID(collectionID)
 		if err != nil {
@@ -127,7 +128,7 @@ func (loader *segmentLoader) LoadSegment(req *querypb.LoadSegmentsRequest, segme
 			return err
 		}
 
-		segment, err := newSegment(collection, segmentID, partitionID, collectionID, "", segmentType)
+		segment, err := newSegment(collection, segmentID, partitionID, collectionID, vChannelID, segmentType)
 		if err != nil {
 			log.Error("load segment failed when create new segment",
 				zap.Int64("collectionID", collectionID),

internal/querynode/task.go

@@ -177,13 +177,14 @@ func (w *watchDmChannelsTask) Execute(ctx context.Context) (err error) {
 			ufInfo := w.req.SegmentInfos[ufInfoID]
 			if len(ufInfo.Binlogs) > 0 {
 				unFlushedSegments = append(unFlushedSegments, &queryPb.SegmentLoadInfo{
-					SegmentID:    ufInfo.ID,
-					PartitionID:  ufInfo.PartitionID,
-					CollectionID: ufInfo.CollectionID,
-					BinlogPaths:  ufInfo.Binlogs,
-					NumOfRows:    ufInfo.NumOfRows,
-					Statslogs:    ufInfo.Statslogs,
-					Deltalogs:    ufInfo.Deltalogs,
+					SegmentID:     ufInfo.ID,
+					PartitionID:   ufInfo.PartitionID,
+					CollectionID:  ufInfo.CollectionID,
+					BinlogPaths:   ufInfo.Binlogs,
+					NumOfRows:     ufInfo.NumOfRows,
+					Statslogs:     ufInfo.Statslogs,
+					Deltalogs:     ufInfo.Deltalogs,
+					InsertChannel: ufInfo.InsertChannel,
 				})
 				unFlushedSegmentIDs = append(unFlushedSegmentIDs, ufInfo.ID)
 			}