We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent be1933e commit 9fdc8ebCopy full SHA for 9fdc8eb
session/session.go
@@ -468,6 +468,7 @@ func (s *session) retry(ctx context.Context, maxCnt uint) error {
468
nh := GetHistory(s)
469
var err error
470
var schemaVersion int64
471
+ orgStartTS := s.GetSessionVars().TxnCtx.StartTS
472
for {
473
s.PrepareTxnCtx(ctx)
474
s.sessionVars.RetryInfo.ResetOffset()
@@ -497,6 +498,8 @@ func (s *session) retry(ctx context.Context, maxCnt uint) error {
497
498
}
499
s.StmtCommit()
500
501
+ log.Warnf("con:%d retrying_txn_start_ts:%d original_txn_start_ts:(%d)",
502
+ connID, s.GetSessionVars().TxnCtx.StartTS, orgStartTS)
503
if hook := ctx.Value("preCommitHook"); hook != nil {
504
// For testing purpose.
505
hook.(func())()
0 commit comments