session: add transaction start timestamp to the log when retrying (pi…

…ngcap#8091)
jackysp · Nov 8, 2018 · 9b4dce7 · 9b4dce7
1 parent 386ea13
commit 9b4dce7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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())()