diff --git a/store/tikv/coprocessor.go b/store/tikv/coprocessor.go index 68ccb27e0f..25bac38da5 100644 --- a/store/tikv/coprocessor.go +++ b/store/tikv/coprocessor.go @@ -765,10 +765,9 @@ func (worker *copIteratorWorker) handleCopStreamResult(bo *Backoffer, rpcCtx *RP } return worker.buildCopTasksFromRemain(bo, lastRange, task) } - if resp.Range == nil { - return nil, errors.New("streaming response should contain a range entry") + if resp.Range != nil { + lastRange = resp.Range } - lastRange = resp.Range } }