diff --git a/internal/querycoord/task.go b/internal/querycoord/task.go index 5bf8628e470bb5b80b8b16e6fefd783ce2e0d472..3575f235a9fc6c9734a2ea5f4409ab95de7a3cb9 100644 --- a/internal/querycoord/task.go +++ b/internal/querycoord/task.go @@ -369,7 +369,6 @@ func (lct *loadCollectionTask) execute(ctx context.Context) error { loadSegmentReqs := make([]*querypb.LoadSegmentsRequest, 0) watchDmChannelReqs := make([]*querypb.WatchDmChannelsRequest, 0) channelsToWatch := make([]string, 0) - segmentsToLoad := make([]UniqueID, 0) var watchDeltaChannels []*datapb.VchannelInfo for _, partitionID := range toLoadPartitionIDs { dmChannelInfos, binlogs, err := getRecoveryInfo(lct.ctx, lct.dataCoord, collectionID, partitionID) @@ -411,7 +410,6 @@ func (lct *loadCollectionTask) execute(ctx context.Context) error { CollectionID: collectionID, } - segmentsToLoad = append(segmentsToLoad, segmentID) loadSegmentReqs = append(loadSegmentReqs, loadSegmentReq) } @@ -737,7 +735,6 @@ func (lpt *loadPartitionTask) execute(ctx context.Context) error { lpt.meta.addPartition(collectionID, id) } - segmentsToLoad := make([]UniqueID, 0) loadSegmentReqs := make([]*querypb.LoadSegmentsRequest, 0) channelsToWatch := make([]string, 0) watchDmReqs := make([]*querypb.WatchDmChannelsRequest, 0) @@ -781,7 +778,6 @@ func (lpt *loadPartitionTask) execute(ctx context.Context) error { LoadCondition: querypb.TriggerCondition_grpcRequest, CollectionID: collectionID, } - segmentsToLoad = append(segmentsToLoad, segmentID) loadSegmentReqs = append(loadSegmentReqs, loadSegmentReq) }