From b22cf68c3616e0fab34813791134ac256120dc2f Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Fri, 24 Dec 2021 19:35:20 +0800 Subject: [PATCH] [skip e2e] Add comment for newServiceTimeNode (#14205) Signed-off-by: bigsheeper --- internal/querynode/flow_graph_service_time_node.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querynode/flow_graph_service_time_node.go b/internal/querynode/flow_graph_service_time_node.go index 465e556380..21682b1561 100644 --- a/internal/querynode/flow_graph_service_time_node.go +++ b/internal/querynode/flow_graph_service_time_node.go @@ -110,6 +110,7 @@ func (stNode *serviceTimeNode) Operate(in []flowgraph.Msg) []flowgraph.Msg { // return stNode.timeTickMsgStream.Produce(&msgPack) //} +// newServiceTimeNode returns a new serviceTimeNode func newServiceTimeNode(ctx context.Context, tSafeReplica TSafeReplicaInterface, collectionID UniqueID,