diff --git a/internal/querynode/flow_graph_insert_node.go b/internal/querynode/flow_graph_insert_node.go
index 2ef75cbc81f3c0b52b0f0459005ed0836f55b658..7e025949d6774ba8f233db68a58a9c396f6d4a78 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)