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

Remove the log for GetFlushableSegments in the datacoord (#27503) 

Signed-off-by: SimFG <bang.fu@zilliz.com>
pull/27517/head
SimFG 2023-10-08 10:05:31 +08:00 committed by GitHub
parent 5ba158a3f5
commit a3188231b3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/datacoord/segment_manager.go
View File

@ -504,11 +504,7 @@ func (s *SegmentManager) GetFlushableSegments(ctx context.Context, channel strin
ret := make([]UniqueID, 0, len(s.segments))
for _, id := range s.segments {
info := s.meta.GetHealthySegment(id)
if info == nil {
continue
}
if info.InsertChannel != channel {
log.Warn("the channel of flushable segments isn't equal", zap.String("insert_channel", info.InsertChannel), zap.String("channel", channel), zap.Int64("segment", id))
if info == nil || info.InsertChannel != channel {
continue
}
if s.flushPolicy(info, t) {