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

Add logs for querynode

Browse Source 
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
This commit is contained in:
Xiangyu Wang 2021-03-30 15:00:14 +08:00 committed by yefu.chen
parent e823b56040
commit 8d66388b8c
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/querynode/search_collection.go
View File

@ -140,6 +140,12 @@ func (s *searchCollection) receiveSearchMsg() {
zap.Int64("collectionID", sm.CollectionID)) zap.Int64("collectionID", sm.CollectionID))
serviceTime := s.getServiceableTime() serviceTime := s.getServiceableTime()
if sm.BeginTs() > serviceTime { if sm.BeginTs() > serviceTime {
log.Debug("querynode::receiveSearchMsg: add to unsolvedMsgs",
zap.Any("sm.BeginTs", sm.BeginTs()),
zap.Any("serviceTime", serviceTime),
zap.Any("delta seconds", (sm.BeginTs()-serviceTime)/(1000*1000*1000)),
zap.Any("collectionID", s.collectionID),
)
s.addToUnsolvedMsg(sm) s.addToUnsolvedMsg(sm)
continue continue
} }
@ -173,6 +179,9 @@ func (s *searchCollection) doUnsolvedMsgSearch() {
default: default:
serviceTime, err := s.waitNewTSafe() serviceTime, err := s.waitNewTSafe()
s.setServiceableTime(serviceTime) s.setServiceableTime(serviceTime)
log.Debug("querynode::doUnsolvedMsgSearch: setServiceableTime",
zap.Any("serviceTime", serviceTime),
)
if err != nil { if err != nil {
// TODO: emptySearch or continue, note: collection has been released // TODO: emptySearch or continue, note: collection has been released
continue continue