From 3e9e7f707bb8b08d01f71124ca95358d6a34a976 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Thu, 9 Dec 2021 14:13:53 +0800 Subject: [PATCH] [skip ci] Add comment for insertNode insert (#13037) Signed-off-by: bigsheeper --- internal/querynode/flow_graph_insert_node.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querynode/flow_graph_insert_node.go b/internal/querynode/flow_graph_insert_node.go index d95046f7a8..370ff00708 100644 --- a/internal/querynode/flow_graph_insert_node.go +++ b/internal/querynode/flow_graph_insert_node.go @@ -265,6 +265,7 @@ func filterSegmentsByPKs(pks []int64, segment *Segment) ([]int64, error) { return res, nil } +// insert would execute insert operations for specific growing segment func (iNode *insertNode) insert(iData *insertData, segmentID UniqueID, wg *sync.WaitGroup) { log.Debug("QueryNode::iNode::insert", zap.Any("SegmentID", segmentID)) var targetSegment, err = iNode.streamingReplica.getSegmentByID(segmentID)