change the buffer size to 4 in the msg dispatch

Signed-off-by: SimFG <bang.fu@zilliz.com>
zilliztech · Jul 24, 2024 · ec20c2f · ec20c2f
1 parent e6322a3
commit ec20c2f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/core/util/milvus_param.go b/core/util/milvus_param.go
@@ -29,5 +29,5 @@ func InitMilvusPkgParam() {
 	innerParam := paramtable.Get()
 	_ = innerParam.Save(innerParam.MQCfg.MaxTolerantLag.Key, "5")
 	_ = innerParam.Save(innerParam.MQCfg.MergeCheckInterval.Key, "2")
-	_ = innerParam.Save(innerParam.MQCfg.TargetBufSize.Key, "16")
+	_ = innerParam.Save(innerParam.MQCfg.TargetBufSize.Key, "4")
 }
diff --git a/server/metrics/metrics.go b/server/metrics/metrics.go
@@ -20,6 +20,7 @@ package metrics
 
 import (
 	"net/http"
+	_ "net/http/pprof"
 
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promhttp"