From 617a0dd6c220c7064948068c71a663b82e596898 Mon Sep 17 00:00:00 2001 From: Alex Shtin Date: Tue, 20 Dec 2022 01:14:14 -0800 Subject: [PATCH] Increase default number of Elasticsearch bulk processor workers to 2 --- service/history/configs/config.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/service/history/configs/config.go b/service/history/configs/config.go index 47834f4e455..54b727a467d 100644 --- a/service/history/configs/config.go +++ b/service/history/configs/config.go @@ -497,7 +497,7 @@ func NewConfig(dc *dynamicconfig.Collection, numberOfShards int32, isAdvancedVis SearchAttributesSizeOfValueLimit: dc.GetIntPropertyFilteredByNamespace(dynamicconfig.SearchAttributesSizeOfValueLimit, 2*1024), SearchAttributesTotalSizeLimit: dc.GetIntPropertyFilteredByNamespace(dynamicconfig.SearchAttributesTotalSizeLimit, 40*1024), IndexerConcurrency: dc.GetIntProperty(dynamicconfig.WorkerIndexerConcurrency, 100), - ESProcessorNumOfWorkers: dc.GetIntProperty(dynamicconfig.WorkerESProcessorNumOfWorkers, 1), + ESProcessorNumOfWorkers: dc.GetIntProperty(dynamicconfig.WorkerESProcessorNumOfWorkers, 2), // Should not be greater than number of visibility task queue workers VisibilityProcessorSchedulerWorkerCount (default 512) // Otherwise, visibility queue processors won't be able to fill up bulk with documents (even under heavy load) and bulk will flush due to interval, not number of actions. ESProcessorBulkActions: dc.GetIntProperty(dynamicconfig.WorkerESProcessorBulkActions, 500),