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

Lower the log frequency when sync tasks are skipped (#25006) 

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/25001/head
yihao.dai 2023-06-20 17:56:41 +08:00 committed by GitHub
parent 8bc5282eb3
commit 6168a55c04
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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_insert_buffer_node.go
View File

@ -474,13 +474,13 @@ func (ibNode *insertBufferNode) Sync(fgMsg *flowGraphMsg, seg2Upload []UniqueID,
) )
// check if task pool is full // check if task pool is full
if !task.dropped && !task.flushed && ibNode.flushManager.isFull() { if !task.dropped && !task.flushed && ibNode.flushManager.isFull() {
log.Warn("task pool is full, skip it") log.RatedWarn(10, "task pool is full, skip it")
continue continue
} }
// check if segment is syncing // check if segment is syncing
segment := ibNode.channel.getSegment(task.segmentID) segment := ibNode.channel.getSegment(task.segmentID)
if !task.dropped && !task.flushed && segment.isSyncing() { if !task.dropped && !task.flushed && segment.isSyncing() {
log.Info("segment is syncing, skip it") log.RatedInfo(10, "segment is syncing, skip it")
continue continue
} }
segment.setSyncing(true) segment.setSyncing(true)