From 4620aebd462a5ecce505187e319cefecb58efa95 Mon Sep 17 00:00:00 2001 From: smellthemoon <64083300+smellthemoon@users.noreply.github.com> Date: Fri, 13 Jan 2023 14:29:41 +0800 Subject: [PATCH] Fix data race (#21706) Signed-off-by: lixinguo Co-authored-by: lixinguo --- internal/proxy/task_upsert.go | 5 ----- 1 file changed, 5 deletions(-) diff --git a/internal/proxy/task_upsert.go b/internal/proxy/task_upsert.go index aedf7c216d..58a2b40894 100644 --- a/internal/proxy/task_upsert.go +++ b/internal/proxy/task_upsert.go @@ -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,