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

fix: unhandle error in upsert task (#36604)

Browse Source 
issue: #36611

Signed-off-by: jaime <yun.zhang@zilliz.com>
This commit is contained in:
jaime 2024-09-30 12:59:16 +08:00 committed by GitHub
parent a25dc98794
commit 5686a9a024
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/proxy/task_upsert.go
View File

@ -464,7 +464,7 @@ func (it *upsertTask) deleteExecute(ctx context.Context, msgPack *msgstream.MsgP
if !ok { if !ok {
msgid, err := it.idAllocator.AllocOne() msgid, err := it.idAllocator.AllocOne()
if err != nil { if err != nil {
errors.Wrap(err, "failed to allocate MsgID for delete of upsert") return errors.Wrap(err, "failed to allocate MsgID for delete of upsert")
} }
sliceRequest := &msgpb.DeleteRequest{ sliceRequest := &msgpb.DeleteRequest{
Base: commonpbutil.NewMsgBase( Base: commonpbutil.NewMsgBase(