From c482255552991128a03f0be3e353fda515dbf67b Mon Sep 17 00:00:00 2001 From: Jack Yu Date: Thu, 8 Nov 2018 14:34:55 +0800 Subject: [PATCH] session: add transaction start timestamp to the log when retrying (#8091) (#8230) --- session/session.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/session/session.go b/session/session.go index 242e7089fd9aa..e6628bac3304a 100644 --- a/session/session.go +++ b/session/session.go @@ -486,6 +486,7 @@ func (s *session) retry(ctx context.Context, maxCnt uint) error { nh := GetHistory(s) var err error + orgStartTS := s.GetSessionVars().TxnCtx.StartTS for { s.PrepareTxnCtx(ctx) s.sessionVars.RetryInfo.ResetOffset() @@ -514,6 +515,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())()