From cc584551fb6c85c8d86fde6012f881a163d559ad Mon Sep 17 00:00:00 2001 From: congqixia Date: Mon, 28 Aug 2023 11:30:26 +0800 Subject: [PATCH] Remove unused hash value setting in DDNode (#26575) Signed-off-by: Congqi Xia --- internal/datanode/flow_graph_dd_node.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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),