diff --git a/session/session_inception.go b/session/session_inception.go
index 2a7d25b4..1c40d149 100644
--- a/session/session_inception.go
+++ b/session/session_inception.go
@@ -1210,6 +1210,7 @@ func (s *session) executeTransaction(records []*Record) int {
 		}
 
 		if len(errs) > 0 {
+			tx.Rollback()
 			log.Errorf("con:%d %v", s.sessionVars.ConnectionID, errs)
 
 			for j := range records {