admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-07 01:28:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

enhance: reduce the log level of frequent log (#35652)

Browse Source 
fix #35651

Signed-off-by: xiaofanluan <xiaofan.luan@zilliz.com>
This commit is contained in:
Xiaofan 2024-08-25 16:20:57 +08:00 committed by GitHub
parent 615a653988
commit 0dc5e89007
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/querycoordv2/meta/coordinator_broker.go
View File

@ -115,14 +115,14 @@ func (broker *CoordinatorBroker) GetCollectionLoadInfo(ctx context.Context, coll
replicaNum, err := common.CollectionLevelReplicaNumber(collectionInfo.GetProperties()) replicaNum, err := common.CollectionLevelReplicaNumber(collectionInfo.GetProperties())
if err != nil { if err != nil {
log.Warn("failed to get collection level load info", zap.Int64("collectionID", collectionID), zap.Error(err)) log.Debug("failed to get collection level load info", zap.Int64("collectionID", collectionID), zap.Error(err))
} else if replicaNum > 0 { } else if replicaNum > 0 {
log.Info("get collection level load info", zap.Int64("collectionID", collectionID), zap.Int64("replica_num", replicaNum)) log.Info("get collection level load info", zap.Int64("collectionID", collectionID), zap.Int64("replica_num", replicaNum))
} }
rgs, err := common.CollectionLevelResourceGroups(collectionInfo.GetProperties()) rgs, err := common.CollectionLevelResourceGroups(collectionInfo.GetProperties())
if err != nil { if err != nil {
log.Warn("failed to get collection level load info", zap.Int64("collectionID", collectionID), zap.Error(err)) log.Debug("failed to get collection level load info", zap.Int64("collectionID", collectionID), zap.Error(err))
} else if len(rgs) > 0 { } else if len(rgs) > 0 {
log.Info("get collection level load info", zap.Int64("collectionID", collectionID), zap.Strings("resource_groups", rgs)) log.Info("get collection level load info", zap.Int64("collectionID", collectionID), zap.Strings("resource_groups", rgs))
} }
@ -136,7 +136,7 @@ func (broker *CoordinatorBroker) GetCollectionLoadInfo(ctx context.Context, coll
if replicaNum <= 0 { if replicaNum <= 0 {
replicaNum, err = common.DatabaseLevelReplicaNumber(dbInfo.GetProperties()) replicaNum, err = common.DatabaseLevelReplicaNumber(dbInfo.GetProperties())
if err != nil { if err != nil {
log.Warn("failed to get database level load info", zap.Int64("collectionID", collectionID), zap.Error(err)) log.Debug("failed to get database level load info", zap.Int64("collectionID", collectionID), zap.Error(err))
} else if replicaNum > 0 { } else if replicaNum > 0 {
log.Info("get database level load info", zap.Int64("collectionID", collectionID), zap.Int64("replica_num", replicaNum)) log.Info("get database level load info", zap.Int64("collectionID", collectionID), zap.Int64("replica_num", replicaNum))
} }
@ -145,7 +145,7 @@ func (broker *CoordinatorBroker) GetCollectionLoadInfo(ctx context.Context, coll
if len(rgs) == 0 { if len(rgs) == 0 {
rgs, err = common.DatabaseLevelResourceGroups(dbInfo.GetProperties()) rgs, err = common.DatabaseLevelResourceGroups(dbInfo.GetProperties())
if err != nil { if err != nil {
log.Warn("failed to get database level load info", zap.Int64("collectionID", collectionID), zap.Error(err)) log.Debug("failed to get database level load info", zap.Int64("collectionID", collectionID), zap.Error(err))
} else if len(rgs) > 0 { } else if len(rgs) > 0 {
log.Info("get database level load info", zap.Int64("collectionID", collectionID), zap.Strings("resource_groups", rgs)) log.Info("get database level load info", zap.Int64("collectionID", collectionID), zap.Strings("resource_groups", rgs))
} }