diff --git a/pkg/index/job/correction/service/corrector.go b/pkg/index/job/correction/service/corrector.go
index 4690a40f2a..7bdcc607ec 100644
--- a/pkg/index/job/correction/service/corrector.go
+++ b/pkg/index/job/correction/service/corrector.go
@@ -19,6 +19,7 @@ import (
 	"io"
 	"os"
 	"path/filepath"
+	"runtime"
 	"sync"
 	"sync/atomic"
 
@@ -287,6 +288,7 @@ func (c *correct) correctWithCache(ctx context.Context) (err error) {
 					delete(tmpSet, k)
 				}
 				tmpSet = nil
+				runtime.GC()
 				// ~DEBUG:
 
 				log.Infof("correction finished for agent %s", addr)