session: reset CTEStorageMap before txn conflict and retry() #49399 (#…

…53353) close #46522
pingcap · May 17, 2024 · 4f182e3 · 4f182e3
1 parent fd44473
commit 4f182e3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/session/session.go b/session/session.go
@@ -1075,6 +1075,7 @@ func (s *session) retry(ctx context.Context, maxCnt uint) (err error) {
 		for i, sr := range nh.history {
 			st := sr.st
 			s.sessionVars.StmtCtx = sr.stmtCtx
+			s.sessionVars.StmtCtx.CTEStorageMap = map[int]*executor.CTEStorages{}
 			s.sessionVars.StmtCtx.ResetForRetry()
 			s.sessionVars.PreparedParams = s.sessionVars.PreparedParams[:0]
 			schemaVersion, err = st.RebuildPlan(ctx)