From 9fdc8ebe5d3d440dcab43dfab470ea44cdb3db25 Mon Sep 17 00:00:00 2001 From: Jack Yu Date: Wed, 7 Nov 2018 16:12:39 +0800 Subject: [PATCH] session: add transaction start timestamp to the log when retrying (#8091) --- session/session.go | 3 +++ 1 file changed, 3 insertions(+) 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())()