diff --git a/internal/datanode/compaction_executor.go b/internal/datanode/compaction_executor.go
index 0ee23255e885d253778e43fa5d6a6a1883494189..39206094592680aee411aa63bb862c0e974e2cc4 100644
--- a/internal/datanode/compaction_executor.go
+++ b/internal/datanode/compaction_executor.go
@@ -18,7 +18,6 @@ package datanode
 
 import (
 	"context"
-	"runtime"
 	"sync"
 
 	"github.com/milvus-io/milvus/internal/log"
@@ -40,11 +39,12 @@ type compactionExecutor struct {
 
 // 0.5*min(8, NumCPU/2)
 func calculeateParallel() int {
-	cores := runtime.NumCPU()
-	if cores < 16 {
-		return 4
-	}
-	return cores / 2
+	return 2
+	//cores := runtime.NumCPU()
+	//if cores < 16 {
+	//return 4
+	//}
+	//return cores / 2
 }
 
 func newCompactionExecutor() *compactionExecutor {