Skip to content

Commit

Permalink
kv: use last range if streaming response does not contain a range ent…
Browse files Browse the repository at this point in the history
…ry (#13062) (#13254)
  • Loading branch information
SunRunAway authored and sre-bot committed Nov 12, 2019
1 parent 64de8d5 commit b2e8afa
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion store/tikv/coprocessor.go
Original file line number Diff line number Diff line change
Expand Up @@ -779,7 +779,9 @@ func (worker *copIteratorWorker) handleCopStreamResult(bo *Backoffer, rpcCtx *RP
logutil.Logger(context.Background()).Info("stream recv timeout", zap.Error(err))
return worker.buildCopTasksFromRemain(bo, lastRange, task)
}
lastRange = resp.Range
if resp.Range != nil {
lastRange = resp.Range
}
}
}

Expand Down

0 comments on commit b2e8afa

Please sign in to comment.