diff --git a/sessiontxn/isolation/base.go b/sessiontxn/isolation/base.go index 97c6abfc3508..f65edd62a32e 100644 --- a/sessiontxn/isolation/base.go +++ b/sessiontxn/isolation/base.go @@ -266,7 +266,9 @@ func (p *baseTxnContextProvider) ActivateTxn() (kv.Transaction, error) { } sessVars := p.sctx.GetSessionVars() + sessVars.TxnCtxMu.Lock() sessVars.TxnCtx.StartTS = txn.StartTS() + sessVars.TxnCtxMu.Unlock() if sessVars.MemDBFootprint != nil { sessVars.MemDBFootprint.Detach() }