Skip to content

Commit

Permalink
store: refine coprocessor error log (#52729)
Browse files Browse the repository at this point in the history
ref #52464
  • Loading branch information
crazycs520 authored Apr 18, 2024
1 parent 53664d4 commit 14c5a78
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions pkg/store/copr/coprocessor.go
Original file line number Diff line number Diff line change
Expand Up @@ -1461,6 +1461,8 @@ func (worker *copIteratorWorker) handleCopResponse(bo *Backoffer, rpcCtx *tikv.R
logutil.Logger(bo.GetCtx()).Warn("other error",
zap.Uint64("txnStartTS", worker.req.StartTs),
zap.Uint64("regionID", task.region.GetID()),
zap.Uint64("regionVer", task.region.GetVer()),
zap.Uint64("regionConfVer", task.region.GetConfVer()),
zap.Uint64("bucketsVer", task.bucketsVer),
zap.Uint64("latestBucketsVer", resp.pbResp.GetLatestBucketsVersion()),
zap.Int("rangeNums", task.ranges.Len()),
Expand Down Expand Up @@ -1591,6 +1593,8 @@ func (worker *copIteratorWorker) handleBatchCopResponse(bo *Backoffer, rpcCtx *t
logutil.Logger(bo.GetCtx()).Warn("other error",
zap.Uint64("txnStartTS", worker.req.StartTs),
zap.Uint64("regionID", task.region.GetID()),
zap.Uint64("regionVer", task.region.GetVer()),
zap.Uint64("regionConfVer", task.region.GetConfVer()),
zap.Uint64("bucketsVer", task.bucketsVer),
// TODO: add bucket version in log
//zap.Uint64("latestBucketsVer", batchResp.GetLatestBucketsVersion()),
Expand Down Expand Up @@ -1618,6 +1622,8 @@ func (worker *copIteratorWorker) handleBatchCopResponse(bo *Backoffer, rpcCtx *t
zap.Uint64("id", task.taskID),
zap.Uint64("txnStartTS", worker.req.StartTs),
zap.Uint64("regionID", task.region.GetID()),
zap.Uint64("regionVer", task.region.GetVer()),
zap.Uint64("regionConfVer", task.region.GetConfVer()),
zap.Uint64("bucketsVer", task.bucketsVer),
zap.Int("rangeNums", task.ranges.Len()),
zap.ByteString("firstRangeStartKey", firstRangeStartKey),
Expand Down

0 comments on commit 14c5a78

Please sign in to comment.