kv: make sure each streaming response does contain a range entry (pin…

…gcap#12907)
cqlxcnp · Oct 28, 2019 · 606a767 · 606a767
1 parent deb7700
commit 606a767
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/store/tikv/coprocessor.go b/store/tikv/coprocessor.go
@@ -765,6 +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")
+		}
 		lastRange = resp.Range
 	}
 }