diff --git a/internal/querynode/flow_graph_query_node.go b/internal/querynode/flow_graph_query_node.go index 6b6c25be08..bd18a40e92 100644 --- a/internal/querynode/flow_graph_query_node.go +++ b/internal/querynode/flow_graph_query_node.go @@ -106,6 +106,7 @@ func newQueryNodeFlowGraph(ctx context.Context, return q } +// newQueryNodeDeltaFlowGraph returns a new queryNodeFlowGraph func newQueryNodeDeltaFlowGraph(ctx context.Context, collectionID UniqueID, historicalReplica ReplicaInterface,