diff --git a/internal/datanode/index/task_stats.go b/internal/datanode/index/task_stats.go index 35068dc7b2..30420617d9 100644 --- a/internal/datanode/index/task_stats.go +++ b/internal/datanode/index/task_stats.go @@ -19,6 +19,7 @@ package index import ( "context" "fmt" + "runtime/debug" "strconv" "time" @@ -267,6 +268,7 @@ func (st *statsTask) sort(ctx context.Context) ([]*datapb.FieldBinlog, error) { st.req.GetInsertChannel(), int64(numValidRows), insertLogs, statsLogs, bm25StatsLogs) + debug.FreeOSMemory() log.Info("sort segment end", zap.String("clusterID", st.req.GetClusterID()), zap.Int64("taskID", st.req.GetTaskID()),