diff --git a/internal/datanode/flow_graph_dd_node.go b/internal/datanode/flow_graph_dd_node.go index 57a37de1dd..ddb21c1aa2 100644 --- a/internal/datanode/flow_graph_dd_node.go +++ b/internal/datanode/flow_graph_dd_node.go @@ -209,9 +209,7 @@ func (ddn *ddNode) Operate(in []Msg) []Msg { log.Debug("DDNode receive delete messages", zap.Int64("numRows", dmsg.NumRows), zap.String("vChannelName", ddn.vChannelName)) - for i := int64(0); i < dmsg.NumRows; i++ { - dmsg.HashValues = append(dmsg.HashValues, uint32(0)) - } + if dmsg.CollectionID != ddn.collectionID { log.Warn("filter invalid DeleteMsg, collection mis-match", zap.Int64("Get collID", dmsg.CollectionID),