From 87251ce295ef7dc25494e0699880ab2d592e2bf7 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Wed, 1 Dec 2021 22:30:06 +0800 Subject: [PATCH] [skip ci] Add comment for filterDeleteNode Operate (#12565) Signed-off-by: bigsheeper --- internal/querynode/flow_graph_filter_delete_node.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querynode/flow_graph_filter_delete_node.go b/internal/querynode/flow_graph_filter_delete_node.go index 381b0e29af..9a6ef91b66 100644 --- a/internal/querynode/flow_graph_filter_delete_node.go +++ b/internal/querynode/flow_graph_filter_delete_node.go @@ -39,6 +39,7 @@ func (fddNode *filterDeleteNode) Name() string { return "fdNode" } +// Operate handles input messages, to filter invalid delete messages func (fddNode *filterDeleteNode) Operate(in []flowgraph.Msg) []flowgraph.Msg { if len(in) != 1 { log.Error("Invalid operate message input in filterDDNode", zap.Int("input length", len(in)))