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

improve: change some frequent log to debug (#32779) 

remove the frequent log "filter insert messages"

Signed-off-by: xiaofanluan <xiaofan.luan@zilliz.com>
pull/32792/head
Xiaofan 2024-05-06 05:51:29 -07:00 committed by GitHub
parent fecd9c21ba
commit 1e47d7afc4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/datanode/flow_graph_dd_node.go
View File

@ -170,14 +170,14 @@ func (ddn *ddNode) Operate(in []Msg) []Msg {
case commonpb.MsgType_Insert: case commonpb.MsgType_Insert:
imsg := msg.(*msgstream.InsertMsg) imsg := msg.(*msgstream.InsertMsg)
if imsg.CollectionID != ddn.collectionID { if imsg.CollectionID != ddn.collectionID {
log.Info("filter invalid insert message, collection mis-match", log.Warn("filter invalid insert message, collection mis-match",
zap.Int64("Get collID", imsg.CollectionID), zap.Int64("Get collID", imsg.CollectionID),
zap.Int64("Expected collID", ddn.collectionID)) zap.Int64("Expected collID", ddn.collectionID))
continue continue
} }
if ddn.tryToFilterSegmentInsertMessages(imsg) { if ddn.tryToFilterSegmentInsertMessages(imsg) {
log.Info("filter insert messages", log.Debug("filter insert messages",
zap.Int64("filter segmentID", imsg.GetSegmentID()), zap.Int64("filter segmentID", imsg.GetSegmentID()),
zap.Uint64("message timestamp", msg.EndTs()), zap.Uint64("message timestamp", msg.EndTs()),
zap.String("segment's vChannel", imsg.GetShardName()), zap.String("segment's vChannel", imsg.GetShardName()),