Skip to content

Commit

Permalink
store: refine coprocessor error log (#52729) (#52876)
Browse files Browse the repository at this point in the history
ref #52464
  • Loading branch information
ti-chi-bot authored May 6, 2024
1 parent dde78dd commit 755a1c2
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 @@ -1467,6 +1467,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 @@ -1597,6 +1599,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 @@ -1624,6 +1628,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 755a1c2

Please sign in to comment.