From c749427bca4996104a0054dcac9c4b95548d4f29 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Tue, 30 Nov 2021 20:09:37 +0800 Subject: [PATCH] [skip ci] Add comment for flowGraph delete (#12488) Signed-off-by: bigsheeper --- internal/querynode/flow_graph_delete_node.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querynode/flow_graph_delete_node.go b/internal/querynode/flow_graph_delete_node.go index b1869e0a5c..0d1b7dc45e 100644 --- a/internal/querynode/flow_graph_delete_node.go +++ b/internal/querynode/flow_graph_delete_node.go @@ -114,6 +114,7 @@ func (dNode *deleteNode) Operate(in []flowgraph.Msg) []flowgraph.Msg { return []Msg{res} } +// delete will do delete operation at segment which id is segmentID func (dNode *deleteNode) delete(deleteData *deleteData, segmentID UniqueID, wg *sync.WaitGroup) { defer wg.Done() log.Debug("QueryNode::dNode::delete", zap.Any("SegmentID", segmentID))