milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Segment Loader Log (#18883) 

Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>

Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
pull/18892/head
Xiaofan 2022-08-29 15:30:57 +08:00 committed by GitHub
parent cea546ba09
commit 56840da74f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/querynode/segment_loader.go
View File

@ -718,11 +718,6 @@ func (loader *segmentLoader) FromDmlCPLoadDelete(ctx context.Context, collection
if dmsg.CollectionID != collectionID {
continue
}
log.Debug("delete pk",
zap.Any("pk", dmsg.PrimaryKeys),
zap.String("vChannelName", position.GetChannelName()),
zap.Any("msg id", position.GetMsgID()),
)
err = processDeleteMessages(loader.metaReplica, segmentTypeSealed, dmsg, delData)
if err != nil {
// TODO: panic?
@ -753,8 +748,8 @@ func (loader *segmentLoader) FromDmlCPLoadDelete(ctx context.Context, collection
for segmentID, pks := range delData.deleteIDs {
segment, err := loader.metaReplica.getSegmentByID(segmentID, segmentTypeSealed)
if err != nil {
log.Warn(err.Error())
continue
log.Warn("failed to get segment", zap.Int64("segment", segmentID), zap.Error(err))
return err
}
offset := segment.segmentPreDelete(len(pks))
delData.deleteOffset[segmentID] = offset