test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-02 11:59:00 +08:00
Code Issues Actions 12 Packages Projects Releases Wiki Activity

Remove unused variables (#13380)

Browse Source 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
congqixia 2021-12-15 11:11:24 +08:00 committed by GitHub
parent 61f2db3102
commit 322f0c5c5c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/querycoord/task.go
View File

@ -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)
}