From 3189681001456e0b71df1aca3cc1e4d437f76498 Mon Sep 17 00:00:00 2001 From: Wei Liu Date: Thu, 2 Jan 2025 16:56:57 +0800 Subject: [PATCH] enhance: Add log for case which target not update as expected Signed-off-by: bigsheeper --- internal/querycoordv2/utils/util.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/querycoordv2/utils/util.go b/internal/querycoordv2/utils/util.go index ccdfc029ad753..36e046bb77d76 100644 --- a/internal/querycoordv2/utils/util.go +++ b/internal/querycoordv2/utils/util.go @@ -47,7 +47,7 @@ func CheckNodeAvailable(nodeID int64, info *session.NodeInfo) error { // 4. All segments of the shard in target should be in the distribution func CheckDelegatorDataReady(nodeMgr *session.NodeManager, targetMgr meta.TargetManagerInterface, leader *meta.LeaderView, scope int32) error { log := log.Ctx(context.TODO()). - WithRateGroup("utils.CheckLeaderAvailable", 1, 60). + WithRateGroup(fmt.Sprintf("util.CheckDelegatorDataReady-%d", leader.CollectionID), 1, 60). With(zap.Int64("leaderID", leader.ID), zap.Int64("collectionID", leader.CollectionID)) info := nodeMgr.Get(leader.ID)