From 65de1a4e4a975208bb6827cbcbe2eb622c4b4b67 Mon Sep 17 00:00:00 2001 From: Yu Shuaipeng Date: Thu, 29 Nov 2018 13:56:46 +0800 Subject: [PATCH] add args info for retry --- session/session.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/session/session.go b/session/session.go index cccfb7a7e8101..628f4632dace9 100644 --- a/session/session.go +++ b/session/session.go @@ -475,7 +475,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) @@ -493,7 +494,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) }