From a4397b5996c9571437169ff06703b9c2d5eebcd0 Mon Sep 17 00:00:00 2001 From: MrPresent-Han Date: Wed, 9 Aug 2023 12:28:56 +0800 Subject: [PATCH] modify default value for sync max parallel to mitigate oom on dn(#26763) Signed-off-by: MrPresent-Han --- configs/milvus.yaml | 2 +- pkg/util/paramtable/component_param.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/configs/milvus.yaml b/configs/milvus.yaml index 5f17529e3a3d3..ac7ab8da3f786 100644 --- a/configs/milvus.yaml +++ b/configs/milvus.yaml @@ -371,7 +371,7 @@ dataNode: flowGraph: maxQueueLength: 16 # Maximum length of task queue in flowgraph maxParallelism: 1024 # Maximum number of tasks executed in parallel in the flowgraph - maxParallelSyncTaskNum: 2 # Maximum number of sync tasks executed in parallel in each flush manager + maxParallelSyncTaskNum: 6 # Maximum number of sync tasks executed in parallel in each flush manager segment: insertBufSize: 16777216 # Max buffer size to flush for a single segment. deleteBufBytes: 67108864 # Max buffer size to flush del for a single channel diff --git a/pkg/util/paramtable/component_param.go b/pkg/util/paramtable/component_param.go index de12f2f6ca6eb..f258b18757573 100644 --- a/pkg/util/paramtable/component_param.go +++ b/pkg/util/paramtable/component_param.go @@ -2398,7 +2398,7 @@ func (p *dataNodeConfig) init(base *BaseTable) { p.MaxParallelSyncTaskNum = ParamItem{ Key: "dataNode.dataSync.maxParallelSyncTaskNum", Version: "2.3.0", - DefaultValue: "2", + DefaultValue: "6", Doc: "Maximum number of sync tasks executed in parallel in each flush manager", Export: true, }