diff --git a/internal/querynode/flow_graph_filter_delete_node.go b/internal/querynode/flow_graph_filter_delete_node.go index 40f04451bf..03fd10622a 100644 --- a/internal/querynode/flow_graph_filter_delete_node.go +++ b/internal/querynode/flow_graph_filter_delete_node.go @@ -113,6 +113,7 @@ func (fddNode *filterDeleteNode) filterInvalidDeleteMessage(msg *msgstream.Delet return msg } +// newFilteredDeleteNode returns a new filterDeleteNode func newFilteredDeleteNode(replica ReplicaInterface, collectionID UniqueID, partitionID UniqueID) *filterDeleteNode {