test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-03 04:19:18 +08:00
Code Issues Actions 13 Packages Projects Releases Wiki Activity

Refine query logs (#20559)

Browse Source 
See also: #20406

Signed-off-by: yangxuan <xuan.yang@zilliz.com>

Signed-off-by: yangxuan <xuan.yang@zilliz.com>
This commit is contained in:
XuanYang-cn 2022-11-15 10:37:08 +08:00 committed by GitHub
parent d37ebe538b
commit 3b45189ce9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/querynode/impl.go
View File

@ -928,7 +928,7 @@ func (node *QueryNode) queryWithDmlChannel(ctx context.Context, req *querypb.Que
}
traceID, _, _ := trace.InfoFromContext(ctx)
log.Ctx(ctx).Debug("Received QueryRequest",
log.Ctx(ctx).Debug("queryWithDmlChannel receives query request",
zap.Bool("fromShardLeader", req.GetFromShardLeader()),
zap.String("vChannel", dmlChannel),
zap.Int64s("segmentIDs", req.GetSegmentIDs()),
@ -949,7 +949,7 @@ func (node *QueryNode) queryWithDmlChannel(ctx context.Context, req *querypb.Que
return failRet, nil
}
log.Ctx(ctx).Debug("start do query",
log.Ctx(ctx).Debug("queryWithDmlChannel starts do query",
zap.Bool("fromShardLeader", req.GetFromShardLeader()),
zap.String("vChannel", dmlChannel),
zap.Int64s("segmentIDs", req.GetSegmentIDs()))
@ -1055,6 +1055,7 @@ func (node *QueryNode) queryWithDmlChannel(ctx context.Context, req *querypb.Que
// Query performs replica query tasks.
func (node *QueryNode) Query(ctx context.Context, req *querypb.QueryRequest) (*internalpb.RetrieveResults, error) {
log.Ctx(ctx).Debug("Received QueryRequest",
zap.Bool("fromShardleader", req.GetFromShardLeader()),
zap.Strings("vChannels", req.GetDmlChannels()),
zap.Int64s("segmentIDs", req.GetSegmentIDs()),
zap.Uint64("guaranteeTimestamp", req.Req.GetGuaranteeTimestamp()),

4
internal/querynode/result.go
View File

@ -253,7 +253,7 @@ func encodeSearchResultData(searchResultData *schemapb.SearchResultData, nq int6
}
func mergeInternalRetrieveResult(ctx context.Context, retrieveResults []*internalpb.RetrieveResults, limit int64) (*internalpb.RetrieveResults, error) {
log.Ctx(ctx).Debug("reduceInternelRetrieveResults",
log.Ctx(ctx).Debug("mergeInternelRetrieveResults",
zap.Int64("limit", limit),
zap.Int("len(retrieveResults)", len(retrieveResults)),
)
@ -313,7 +313,7 @@ func mergeInternalRetrieveResult(ctx context.Context, retrieveResults []*interna
}
func mergeSegcoreRetrieveResults(ctx context.Context, retrieveResults []*segcorepb.RetrieveResults, limit int64) (*segcorepb.RetrieveResults, error) {
log.Ctx(ctx).Debug("reduceSegcoreRetrieveResults",
log.Ctx(ctx).Debug("mergeSegcoreRetrieveResults",
zap.Int64("limit", limit),
zap.Int("len(retrieveResults)", len(retrieveResults)),
)