From 2512ca3684b566ce36587c11276b3c1023097058 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Fri, 3 Dec 2021 20:39:33 +0800 Subject: [PATCH] [skip ci] Add comment for filterInvalidInsertMessage (#12734) 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 d2034cf84..2b13ae32b 100644 --- a/internal/querynode/flow_graph_filter_dm_node.go +++ b/internal/querynode/flow_graph_filter_dm_node.go @@ -165,6 +165,7 @@ func (fdmNode *filterDmNode) filterInvalidDeleteMessage(msg *msgstream.DeleteMsg return msg } +// filterInvalidInsertMessage would filter out invalid insert messages func (fdmNode *filterDmNode) filterInvalidInsertMessage(msg *msgstream.InsertMsg) *msgstream.InsertMsg { sp, ctx := trace.StartSpanFromContext(msg.TraceCtx()) msg.SetTraceCtx(ctx) -- GitLab