mirror of https://github.com/milvus-io/milvus.git
[skip ci] Add comment for insertNode insert (#13037)
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>pull/13056/head
parent
b206980feb
commit
3e9e7f707b
|
@ -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)
|
||||
|
|
Loading…
Reference in New Issue