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)))