diff --git a/session/session.go b/session/session.go index c4cc5f83ff551..926677fa5fb3b 100644 --- a/session/session.go +++ b/session/session.go @@ -2049,7 +2049,7 @@ func (s *session) PrepareTxnCtx(ctx context.Context) { SchemaVersion: is.SchemaMetaVersion(), CreateTime: time.Now(), } - if !s.sessionVars.IsAutocommit() { + if !s.sessionVars.IsAutocommit() || s.sessionVars.RetryInfo.Retrying { pessTxnConf := config.GetGlobalConfig().PessimisticTxn if pessTxnConf.Enable { if s.sessionVars.TxnMode == ast.Pessimistic {