milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Refine query logs (#20559) (#20583) 

See also: #20406

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

Signed-off-by: yangxuan <xuan.yang@zilliz.com>
pull/20542/head
XuanYang-cn 2022-11-15 12:25:07 +08:00 committed by GitHub
parent 5cfff621ac
commit 663d4259d9
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

@ -930,7 +930,7 @@ func (node *QueryNode) queryWithDmlChannel(ctx context.Context, req *querypb.Que
}
msgID := req.GetReq().GetBase().GetMsgID()
log.Ctx(ctx).Debug("Received QueryRequest",
log.Ctx(ctx).Debug("queryWithDmlChannel receives query request",
zap.Int64("msgID", msgID),
zap.Bool("fromShardLeader", req.GetFromShardLeader()),
zap.String("vChannel", dmlChannel),
@ -950,7 +950,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.Int64("msgID", msgID),
zap.Bool("fromShardLeader", req.GetFromShardLeader()),
zap.String("vChannel", dmlChannel),
@ -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.Int64("msgID", req.GetReq().GetBase().GetMsgID()),
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)),
)