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

Improve rated log in insertBufferNode (#26788) 

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/26725/head
yihao.dai 2023-09-04 09:59:10 +08:00 committed by GitHub
parent 3349db4aa7
commit 7624c2b949
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/datanode/flow_graph_insert_buffer_node.go
View File

@ -459,7 +459,7 @@ func (ibNode *insertBufferNode) Sync(fgMsg *flowGraphMsg, seg2Upload []UniqueID,
zap.Bool("auto", task.auto),
zap.Any("position", endPosition),
zap.String("channel", ibNode.channelName),
)
).WithRateGroup("ibNode.sync", 1, 60)
// check if segment is syncing
segment := ibNode.channel.getSegment(task.segmentID)
if !task.dropped && !task.flushed && segment.isSyncing() {

3
internal/rootcoord/quota_center.go
View File

@ -412,9 +412,6 @@ func (q *QuotaCenter) calculateReadRates() {
q.guaranteeMinRate(getCollectionRateLimitConfig(collectionProps, common.CollectionSearchRateMinKey), internalpb.RateType_DQLSearch, collection)
q.guaranteeMinRate(getCollectionRateLimitConfig(collectionProps, common.CollectionQueryRateMinKey), internalpb.RateType_DQLQuery, collection)
}
log.RatedInfo(10, "QueryNodeMetrics when cool-off",
zap.Any("metrics", q.queryNodeMetrics))
}
// TODO: unify search and query?