From 788ea53f4fc761094c298c4b64495d50d8cd3066 Mon Sep 17 00:00:00 2001 From: yukun Date: Wed, 27 Oct 2021 18:01:15 +0800 Subject: [PATCH] [skip ci]Fix flow_graph_insert_node comment (#10749) Signed-off-by: fishpenguin --- internal/querynode/flow_graph_insert_node.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/querynode/flow_graph_insert_node.go b/internal/querynode/flow_graph_insert_node.go index 2ef75cbc8..7e025949d 100644 --- a/internal/querynode/flow_graph_insert_node.go +++ b/internal/querynode/flow_graph_insert_node.go @@ -155,14 +155,14 @@ func (iNode *insertNode) Operate(in []flowgraph.Msg) []flowgraph.Msg { } } - // 2. do predelete + // 2. do preDelete for segmentID, pks := range delData.deleteIDs { segment := iNode.getSegmentInReplica(segmentID) offset := segment.segmentPreDelete(len(pks)) delData.deleteOffset[segmentID] = offset } - // 2. do delete + // 3. do delete for segmentID := range delData.deleteIDs { wg.Add(1) go iNode.delete(delData, segmentID, &wg) -- GitLab