From 2a98ce272ed78a961ab90b9c1ee9f4883ea4e0f1 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Fri, 3 Dec 2021 20:37:38 +0800 Subject: [PATCH] [skip ci] Add comment for filterInvalidDeleteMessage (#12733) Signed-off-by: bigsheeper --- internal/querynode/flow_graph_filter_dm_node.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querynode/flow_graph_filter_dm_node.go b/internal/querynode/flow_graph_filter_dm_node.go index f35372433..d2034cf84 100644 --- a/internal/querynode/flow_graph_filter_dm_node.go +++ b/internal/querynode/flow_graph_filter_dm_node.go @@ -104,6 +104,7 @@ func (fdmNode *filterDmNode) Operate(in []flowgraph.Msg) []flowgraph.Msg { return []Msg{res} } +// filterInvalidDeleteMessage would filter out invalid delete messages func (fdmNode *filterDmNode) filterInvalidDeleteMessage(msg *msgstream.DeleteMsg) *msgstream.DeleteMsg { sp, ctx := trace.StartSpanFromContext(msg.TraceCtx()) msg.SetTraceCtx(ctx) -- GitLab