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,