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

Reduce the log of proxy (#6766) 

Signed-off-by: dragondriver <jiquan.long@zilliz.com>
pull/6783/head
dragondriver 2021-07-23 20:33:34 +08:00 committed by GitHub
parent c633e579a5
commit cf8e9d52b1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/proxy/task.go
View File

@ -1620,7 +1620,7 @@ func decodeSearchResultsSerial(searchResults []*internalpb.SearchResults) ([]*sc
results := make([]*schemapb.SearchResultData, 0) results := make([]*schemapb.SearchResultData, 0)
// necessary to parallel this? // necessary to parallel this?
for i, partialSearchResult := range searchResults { for i, partialSearchResult := range searchResults {
log.Debug("decodeSearchResultsSerial", zap.Any("i", i), zap.Any("SlicedBob", partialSearchResult.SlicedBlob)) log.Debug("decodeSearchResultsSerial", zap.Any("i", i), zap.Any("len(SlicedBob)", len(partialSearchResult.SlicedBlob)))
if partialSearchResult.SlicedBlob == nil { if partialSearchResult.SlicedBlob == nil {
continue continue
} }

8
internal/proxy/task_scheduler.go
View File

@ -701,7 +701,7 @@ func (sched *TaskScheduler) collectResultLoop() {
continue continue
} }
t := sched.getTaskByReqID(reqID) t := sched.getTaskByReqID(reqID)
log.Debug("Proxy collectResultLoop Got a SearchResultMsg", zap.Any("ReqID", reqID), zap.Any("t", t)) log.Debug("Proxy collectResultLoop Got a SearchResultMsg", zap.Any("ReqID", reqID))
if t == nil { if t == nil {
log.Debug("Proxy collectResultLoop GetTaskByReqID failed", zap.String("reqID", reqIDStr)) log.Debug("Proxy collectResultLoop GetTaskByReqID failed", zap.String("reqID", reqIDStr))
delete(searchResultBufs, reqID) delete(searchResultBufs, reqID)
@ -711,7 +711,7 @@ func (sched *TaskScheduler) collectResultLoop() {
st, ok := t.(*SearchTask) st, ok := t.(*SearchTask)
if !ok { if !ok {
log.Debug("Proxy collectResultLoop type assert t as SearchTask failed", zap.Any("t", t)) log.Debug("Proxy collectResultLoop type assert t as SearchTask failed", zap.Any("ReqID", reqID))
delete(searchResultBufs, reqID) delete(searchResultBufs, reqID)
searchResultBufFlags[reqID] = true searchResultBufFlags[reqID] = true
continue continue
@ -800,7 +800,7 @@ func (sched *TaskScheduler) collectResultLoop() {
continue continue
} }
t := sched.getTaskByReqID(reqID) t := sched.getTaskByReqID(reqID)
log.Debug("Proxy collectResultLoop Got a queryResultMsg", zap.Any("ReqID", reqID), zap.Any("t", t)) log.Debug("Proxy collectResultLoop Got a queryResultMsg", zap.Any("ReqID", reqID))
if t == nil { if t == nil {
log.Debug("Proxy collectResultLoop GetTaskByReqID failed", zap.String("reqID", reqIDStr)) log.Debug("Proxy collectResultLoop GetTaskByReqID failed", zap.String("reqID", reqIDStr))
delete(queryResultBufs, reqID) delete(queryResultBufs, reqID)
@ -810,7 +810,7 @@ func (sched *TaskScheduler) collectResultLoop() {
st, ok := t.(*RetrieveTask) st, ok := t.(*RetrieveTask)
if !ok { if !ok {
log.Debug("Proxy collectResultLoop type assert t as RetrieveTask failed", zap.Any("t", t)) log.Debug("Proxy collectResultLoop type assert t as RetrieveTask failed")
delete(queryResultBufs, reqID) delete(queryResultBufs, reqID)
queryResultBufFlags[reqID] = true queryResultBufFlags[reqID] = true
continue continue