executor: reuse the memory from analyze result (#47617)

ref #47275

pkg/executor/analyze.go

@@ -399,8 +399,10 @@ func (e *AnalyzeExec) handleResultsError(
 		}
 		if atomic.LoadUint32(&e.Ctx().GetSessionVars().Killed) == 1 {
 			finishJobWithLog(e.Ctx(), results.Job, exeerrors.ErrQueryInterrupted)
+			results.DestroyAndPutToPool()
 			return errors.Trace(exeerrors.ErrQueryInterrupted)
 		}
+		results.DestroyAndPutToPool()
 	}
 	// Dump stats to historical storage.
 	for tableID := range tableIDs {

pkg/executor/analyze_worker.go

@@ -68,6 +68,7 @@ func (worker *analyzeSaveStatsWorker) run(ctx context.Context, analyzeSnapshot b
 		} else {
 			finishJobWithLog(worker.sctx, results.Job, nil)
 		}
+		results.DestroyAndPutToPool()
 		if err != nil {
 			return
 		}

pkg/statistics/analyze.go

@@ -69,6 +69,13 @@ type AnalyzeResult struct {
 	IsIndex int
 }
 
+// DestroyAndPutToPool destroys the result and put it to the pool.
+func (a *AnalyzeResult) DestroyAndPutToPool() {
+	for _, f := range a.Fms {
+		f.DestroyAndPutToPool()
+	}
+}
+
 // AnalyzeResults represents the analyze results of a task.
 type AnalyzeResults struct {
 	Err      error
@@ -100,3 +107,10 @@ type AnalyzeResults struct {
 	// table-level fields, we only need to update the version.
 	ForMVIndex bool
 }
+
+// DestroyAndPutToPool destroys the result and put it to the pool.
+func (a *AnalyzeResults) DestroyAndPutToPool() {
+	for _, f := range a.Ars {
+		f.DestroyAndPutToPool()
+	}
+}