From 4f4a417c8f0159b9707628f0740c86a7aca7580f Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Wed, 6 Apr 2022 14:09:35 +0800 Subject: [PATCH] Unify in log print (#16368) Signed-off-by: bigsheeper --- internal/querynode/query_node.go | 2 +- internal/querynode/task.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/querynode/query_node.go b/internal/querynode/query_node.go index 27c9d46d32..b7fd5053cf 100644 --- a/internal/querynode/query_node.go +++ b/internal/querynode/query_node.go @@ -492,7 +492,7 @@ func (node *QueryNode) waitChangeInfo(segmentChangeInfos *querypb.SealedSegments return retry.Do(node.queryNodeLoopCtx, fn, retry.Attempts(50)) } -// remove the segments since it's already compacted or balanced to other querynodes +// remove the segments since it's already compacted or balanced to other QueryNodes func (node *QueryNode) removeSegments(segmentChangeInfos *querypb.SealedSegmentsChangeInfo) error { err := node.waitChangeInfo(segmentChangeInfos) if err != nil { diff --git a/internal/querynode/task.go b/internal/querynode/task.go index f08179d98c..ae1f8e7b19 100644 --- a/internal/querynode/task.go +++ b/internal/querynode/task.go @@ -171,7 +171,7 @@ func (r *addQueryChannelTask) Execute(ctx context.Context) error { if err != nil { return err } - log.Debug("querynode seek query channel: ", zap.Any("consumeChannels", consumeChannels), + log.Debug("QueryNode seek query channel: ", zap.Any("consumeChannels", consumeChannels), zap.String("seek position", string(r.req.SeekPosition.MsgID))) }