admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-08 18:18:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix query task panicking (#8060)

Browse Source 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
congqixia 2021-09-16 20:03:50 +08:00 committed by GitHub
parent 41cb0f30cb
commit 4fe22bcaaa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/proxy/task.go
View File

@ -2464,13 +2464,14 @@ func (qt *queryTask) PostExecute(ctx context.Context) error {
}, },
FieldsData: make([]*schemapb.FieldData, 0), FieldsData: make([]*schemapb.FieldData, 0),
} }
for idx, partialRetrieveResult := range retrieveResult { for _, partialRetrieveResult := range retrieveResult {
availableQueryNodeNum++ availableQueryNodeNum++
if partialRetrieveResult.Ids == nil { if partialRetrieveResult.Ids == nil {
reason += "ids is nil\n" reason += "ids is nil\n"
continue continue
} else { } else {
if idx == 0 { // handles initialization, cannot use idx==0 since first result may be empty
if len(qt.result.FieldsData) == 0 {
qt.result.FieldsData = append(qt.result.FieldsData, partialRetrieveResult.FieldsData...) qt.result.FieldsData = append(qt.result.FieldsData, partialRetrieveResult.FieldsData...)
} else { } else {
for k, fieldData := range partialRetrieveResult.FieldsData { for k, fieldData := range partialRetrieveResult.FieldsData {