diff --git a/internal/proxy/task.go b/internal/proxy/task.go index 95276a100f..1dabf5f430 100644 --- a/internal/proxy/task.go +++ b/internal/proxy/task.go @@ -1620,7 +1620,7 @@ func decodeSearchResultsSerial(searchResults []*internalpb.SearchResults) ([]*sc results := make([]*schemapb.SearchResultData, 0) // necessary to parallel this? 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 { continue } diff --git a/internal/proxy/task_scheduler.go b/internal/proxy/task_scheduler.go index 6c90917969..644afc01b5 100644 --- a/internal/proxy/task_scheduler.go +++ b/internal/proxy/task_scheduler.go @@ -701,7 +701,7 @@ func (sched *TaskScheduler) collectResultLoop() { continue } 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 { log.Debug("Proxy collectResultLoop GetTaskByReqID failed", zap.String("reqID", reqIDStr)) delete(searchResultBufs, reqID) @@ -711,7 +711,7 @@ func (sched *TaskScheduler) collectResultLoop() { st, ok := t.(*SearchTask) 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) searchResultBufFlags[reqID] = true continue @@ -800,7 +800,7 @@ func (sched *TaskScheduler) collectResultLoop() { continue } 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 { log.Debug("Proxy collectResultLoop GetTaskByReqID failed", zap.String("reqID", reqIDStr)) delete(queryResultBufs, reqID) @@ -810,7 +810,7 @@ func (sched *TaskScheduler) collectResultLoop() { st, ok := t.(*RetrieveTask) 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) queryResultBufFlags[reqID] = true continue