From 0201f4f87844564e25e5bc541aad39bee9dd88fa Mon Sep 17 00:00:00 2001 From: Feng Liyuan Date: Mon, 4 Nov 2019 15:30:40 +0800 Subject: [PATCH] kv: use last range if streaming response does not contain a range entry (#13062) --- store/tikv/coprocessor.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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 } }