From a126dd9d43217489491dcf20b0b1af2b27910677 Mon Sep 17 00:00:00 2001 From: Jack Yu Date: Thu, 29 Nov 2018 15:20:43 +0800 Subject: [PATCH] add args info for retry (#8506) --- session/session.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/session/session.go b/session/session.go index 94fc0309563a9..3ed02bc721728 100644 --- a/session/session.go +++ b/session/session.go @@ -510,7 +510,8 @@ func (s *session) retry(ctx context.Context, maxCnt uint) error { nh := GetHistory(s) var err error var schemaVersion int64 - orgStartTS := s.GetSessionVars().TxnCtx.StartTS + sessVars := s.GetSessionVars() + orgStartTS := sessVars.TxnCtx.StartTS label := s.getSQLLabel() for { s.PrepareTxnCtx(ctx) @@ -528,7 +529,8 @@ func (s *session) retry(ctx context.Context, maxCnt uint) error { if retryCnt == 0 { // We do not have to log the query every time. // We print the queries at the first try only. - log.Warnf("con:%d schema_ver:%d retry_cnt:%d query_num:%d sql:%s", connID, schemaVersion, retryCnt, i, sqlForLog(st.OriginText())) + log.Warnf("con:%d schema_ver:%d retry_cnt:%d query_num:%d sql:%s%s", connID, schemaVersion, retryCnt, + i, sqlForLog(st.OriginText()), sessVars.GetExecuteArgumentsInfo()) } else { log.Warnf("con:%d schema_ver:%d retry_cnt:%d query_num:%d", connID, schemaVersion, retryCnt, i) }