From 41b75133b8178d20e76dfbdc5853fbc16ad6e7c9 Mon Sep 17 00:00:00 2001 From: you06 Date: Tue, 13 Dec 2022 15:33:52 +0800 Subject: [PATCH] address comment Signed-off-by: you06 --- store/copr/coprocessor.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/store/copr/coprocessor.go b/store/copr/coprocessor.go index 1c8575892af4a..390c5ffe8e63a 100644 --- a/store/copr/coprocessor.go +++ b/store/copr/coprocessor.go @@ -1337,6 +1337,7 @@ func (worker *copIteratorWorker) handleBatchRemainsOnErr(bo *Backoffer, remains } // handle the batched cop response. +// tasks will be changed, so the input tasks should not be used after calling this function. func (worker *copIteratorWorker) handleBatchCopResponse(bo *Backoffer, batchResps []*coprocessor.StoreBatchTaskResponse, tasks map[uint64]*batchedCopTask, ch chan<- *copResponse) ([]*copTask, error) { if len(tasks) == 0 { return nil, nil @@ -1414,7 +1415,7 @@ func (worker *copIteratorWorker) handleBatchCopResponse(bo *Backoffer, batchResp if len(batchResps) != 0 { firstRangeStartKey := task.ranges.At(0).StartKey lastRangeEndKey := task.ranges.At(task.ranges.Len() - 1).EndKey - logutil.Logger(bo.GetCtx()).Warn("response of batched task missing", + logutil.Logger(bo.GetCtx()).Error("response of batched task missing", zap.Uint64("id", task.taskID), zap.Uint64("txnStartTS", worker.req.StartTs), zap.Uint64("regionID", task.region.GetID()),