diff --git a/common/persistence/persistenceRateLimitedClients.go b/common/persistence/persistenceRateLimitedClients.go index 53dc8e29eed..77836571729 100644 --- a/common/persistence/persistenceRateLimitedClients.go +++ b/common/persistence/persistenceRateLimitedClients.go @@ -31,8 +31,6 @@ import ( var ( // ErrPersistenceLimitExceeded is the error indicating QPS limit reached. ErrPersistenceLimitExceeded = &workflow.ServiceBusyError{Message: "Persistence Max QPS Reached."} - // ErrPersistenceLimitExceededForList is the error indicating QPS limit reached for list visibility. - ErrPersistenceLimitExceededForList = &workflow.ServiceBusyError{Message: "Persistence Max QPS Reached for List Operations."} ) type ( diff --git a/common/persistence/visibilitySamplingClient.go b/common/persistence/visibilitySamplingClient.go index da4f9b5d206..05c74a46d63 100644 --- a/common/persistence/visibilitySamplingClient.go +++ b/common/persistence/visibilitySamplingClient.go @@ -40,6 +40,9 @@ const ( numOfPriorityForList = 1 ) +// ErrPersistenceLimitExceededForList is the error indicating QPS limit reached for list visibility. +var ErrPersistenceLimitExceededForList = &workflow.ServiceBusyError{Message: "Persistence Max QPS Reached for List Operations."} + type visibilitySamplingClient struct { rateLimitersForOpen *domainToBucketMap rateLimitersForClosed *domainToBucketMap diff --git a/service/frontend/service.go b/service/frontend/service.go index e6d6c23a9b8..8cb5f428093 100644 --- a/service/frontend/service.go +++ b/service/frontend/service.go @@ -104,9 +104,9 @@ func NewConfig(dc *dynamicconfig.Collection, numHistoryShards int, enableReadFro VisibilityMaxPageSize: dc.GetIntPropertyFilteredByDomain(dynamicconfig.FrontendVisibilityMaxPageSize, 1000), EnableVisibilitySampling: dc.GetBoolProperty(dynamicconfig.EnableVisibilitySampling, true), EnableReadFromClosedExecutionV2: dc.GetBoolProperty(dynamicconfig.EnableReadFromClosedExecutionV2, false), - VisibilityListMaxQPS: dc.GetIntPropertyFilteredByDomain(dynamicconfig.FrontendVisibilityListMaxQPS, 1), + VisibilityListMaxQPS: dc.GetIntPropertyFilteredByDomain(dynamicconfig.FrontendVisibilityListMaxQPS, 10), + ESVisibilityListMaxQPS: dc.GetIntPropertyFilteredByDomain(dynamicconfig.FrontendESVisibilityListMaxQPS, 30), EnableReadVisibilityFromES: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.EnableReadVisibilityFromES, enableReadFromES), - ESVisibilityListMaxQPS: dc.GetIntPropertyFilteredByDomain(dynamicconfig.FrontendESVisibilityListMaxQPS, 3), ESIndexMaxResultWindow: dc.GetIntProperty(dynamicconfig.FrontendESIndexMaxResultWindow, 10000), HistoryMaxPageSize: dc.GetIntPropertyFilteredByDomain(dynamicconfig.FrontendHistoryMaxPageSize, common.GetHistoryMaxPageSize), RPS: dc.GetIntProperty(dynamicconfig.FrontendRPS, 1200),