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

Fix data race (#21706)

Browse Source 
Signed-off-by: lixinguo <xinguo.li@zilliz.com>
Co-authored-by: lixinguo <xinguo.li@zilliz.com>
This commit is contained in:
smellthemoon 2023-01-13 14:29:41 +08:00 committed by GitHub
parent 782f942b6f
commit 4620aebd46
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/proxy/task_upsert.go
View File

@ -241,11 +241,6 @@ func (it *upsertTask) PreExecute(ctx context.Context) error {
defer sp.End()
log := log.Ctx(ctx).With(zap.String("collectionName", it.req.CollectionName))
it.req.Base = commonpbutil.NewMsgBase(
commonpbutil.WithMsgType(commonpb.MsgType(commonpb.MsgType_Upsert)),
commonpbutil.WithSourceID(paramtable.GetNodeID()),
)
it.result = &milvuspb.MutationResult{
Status: &commonpb.Status{
ErrorCode: commonpb.ErrorCode_Success,