diff --git a/internal/proxy/task_scheduler.go b/internal/proxy/task_scheduler.go index 1474fd422d..b0390eae92 100644 --- a/internal/proxy/task_scheduler.go +++ b/internal/proxy/task_scheduler.go @@ -651,7 +651,7 @@ func (sched *taskScheduler) collectResultLoop() { defer queryResultMsgStream.Close() searchResultBufs := make(map[UniqueID]*searchResultBuf) - searchResultBufFlags := make(map[UniqueID]bool) // if value is true, we can ignore queryResult + searchResultBufFlags := make(map[UniqueID]bool) // if value is true, we can ignore searchResult queryResultBufs := make(map[UniqueID]*queryResultBuf) queryResultBufFlags := make(map[UniqueID]bool) // if value is true, we can ignore queryResult