未验证 提交 788ea53f 编写于 作者: Y yukun 提交者: GitHub

[skip ci]Fix flow_graph_insert_node comment (#10749)

Signed-off-by: Nfishpenguin <kun.yu@zilliz.com>
上级 a4c11731
......@@ -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)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册