From f7368e35a443ef3adeb6308235e653745ee9b51e Mon Sep 17 00:00:00 2001 From: xige-16 Date: Thu, 6 Jan 2022 23:26:18 +0800 Subject: [PATCH] Add log for LoadSegmentsTask (#14703) Signed-off-by: xige-16 --- internal/querynode/impl.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/querynode/impl.go b/internal/querynode/impl.go index f2abee4873..4f9d6641a7 100644 --- a/internal/querynode/impl.go +++ b/internal/querynode/impl.go @@ -330,7 +330,7 @@ func (node *QueryNode) LoadSegments(ctx context.Context, in *queryPb.LoadSegment for _, info := range in.Infos { segmentIDs = append(segmentIDs, info.SegmentID) } - log.Debug("loadSegmentsTask Enqueue done", zap.Int64s("segmentIDs", segmentIDs)) + log.Debug("loadSegmentsTask Enqueue done", zap.Int64("collectionID", in.CollectionID), zap.Int64s("segmentIDs", segmentIDs), zap.Int64("nodeID", Params.QueryNodeCfg.QueryNodeID)) waitFunc := func() (*commonpb.Status, error) { err = dct.WaitToFinish() @@ -342,7 +342,7 @@ func (node *QueryNode) LoadSegments(ctx context.Context, in *queryPb.LoadSegment log.Error(err.Error()) return status, nil } - log.Debug("loadSegmentsTask WaitToFinish done", zap.Int64s("segmentIDs", segmentIDs)) + log.Debug("loadSegmentsTask WaitToFinish done", zap.Int64("collectionID", in.CollectionID), zap.Int64s("segmentIDs", segmentIDs), zap.Int64("nodeID", Params.QueryNodeCfg.QueryNodeID)) return &commonpb.Status{ ErrorCode: commonpb.ErrorCode_Success, }, nil