diff --git a/session/session.go b/session/session.go index c52d2fb71fda4..711ab8f9e9673 100644 --- a/session/session.go +++ b/session/session.go @@ -468,6 +468,7 @@ func (s *session) retry(ctx context.Context, maxCnt uint) error { nh := GetHistory(s) var err error var schemaVersion int64 + orgStartTS := s.GetSessionVars().TxnCtx.StartTS for { s.PrepareTxnCtx(ctx) s.sessionVars.RetryInfo.ResetOffset() @@ -497,6 +498,8 @@ func (s *session) retry(ctx context.Context, maxCnt uint) error { } s.StmtCommit() } + log.Warnf("con:%d retrying_txn_start_ts:%d original_txn_start_ts:(%d)", + connID, s.GetSessionVars().TxnCtx.StartTS, orgStartTS) if hook := ctx.Value("preCommitHook"); hook != nil { // For testing purpose. hook.(func())()