where is the code that data node and query node handles the insert and delete which are part of upsert

[ron-gilaad]

Hi,
The Execute function of the upsertTask calls stream.Produce(msgPack) to send the DML operations encapsulated in msgPack (which contains the insert and delete operations) to the stream for further processing by data and query nodes. Where is the code that data node and query node handles it?

[yhmo]

In v2.4, datanode processes insert messages in this place:

milvus/internal/datanode/flow_graph_dd_node.go

Line 164 in 1d9c746

case commonpb.MsgType_Insert:

querynode processes insert message in this place:

milvus/internal/querynodev2/pipeline/insert_node.go

Line 89 in 1d9c746

func (iNode *insertNode) Operate(in Msg) Msg {

In master branch, datanode processes insert messages in this place:

milvus/internal/flushcommon/pipeline/flow_graph_dd_node.go

Line 172 in 5a1f752

case commonpb.MsgType_Insert:

[ron-gilaad]

thanks @yhmo I found it myself according to the log