milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix missing totalChannelNum bug (#26295) 

Signed-off-by: chasingegg <chao.gao@zilliz.com>
pull/26304/head
Gao 2023-08-11 18:35:29 +08:00 committed by GitHub
parent 48422dd4c5
commit 9ca8f28005
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
internal/querynodev2/services.go
View File

@ -821,6 +821,7 @@ func (node *QueryNode) Search(ctx context.Context, req *querypb.SearchRequest) (
SegmentIDs: req.SegmentIDs, SegmentIDs: req.SegmentIDs,
FromShardLeader: req.FromShardLeader, FromShardLeader: req.FromShardLeader,
Scope: req.Scope, Scope: req.Scope,
TotalChannelNum: req.TotalChannelNum,
} }
runningGp.Go(func() error { runningGp.Go(func() error {

4
internal/querynodev2/services_test.go
View File

@ -1091,6 +1091,7 @@ func (suite *ServiceSuite) TestSearch_Normal() {
Req: creq, Req: creq,
FromShardLeader: false, FromShardLeader: false,
DmlChannels: []string{suite.vchannel}, DmlChannels: []string{suite.vchannel},
TotalChannelNum: 2,
} }
suite.NoError(err) suite.NoError(err)
@ -1117,6 +1118,7 @@ func (suite *ServiceSuite) TestSearch_Concurrent() {
Req: creq, Req: creq,
FromShardLeader: false, FromShardLeader: false,
DmlChannels: []string{suite.vchannel}, DmlChannels: []string{suite.vchannel},
TotalChannelNum: 2,
} }
suite.NoError(err) suite.NoError(err)
return suite.node.Search(ctx, req) return suite.node.Search(ctx, req)
@ -1142,6 +1144,7 @@ func (suite *ServiceSuite) TestSearch_Failed() {
Req: creq, Req: creq,
FromShardLeader: false, FromShardLeader: false,
DmlChannels: []string{suite.vchannel}, DmlChannels: []string{suite.vchannel},
TotalChannelNum: 2,
} }
suite.NoError(err) suite.NoError(err)
@ -1201,6 +1204,7 @@ func (suite *ServiceSuite) TestSearchSegments_Normal() {
Req: creq, Req: creq,
FromShardLeader: true, FromShardLeader: true,
DmlChannels: []string{suite.vchannel}, DmlChannels: []string{suite.vchannel},
TotalChannelNum: 2,
} }
suite.NoError(err) suite.NoError(err)