Skip to content

Commit

Permalink
Double inline archival time limit defaults (uber#4796)
Browse files Browse the repository at this point in the history
  • Loading branch information
vytautas-karpavicius authored Apr 11, 2022
1 parent 807a0e2 commit 480c733
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions common/dynamicconfig/constants.go
Original file line number Diff line number Diff line change
Expand Up @@ -1073,7 +1073,7 @@ const (
// TimerProcessorArchivalTimeLimit is the upper time limit for inline history archival
// KeyName: history.timerProcessorArchivalTimeLimit
// Value type: Duration
// Default value: 1s (1*time.Second)
// Default value: 2s (2*time.Second)
// Allowed filters: N/A
TimerProcessorArchivalTimeLimit

Expand Down Expand Up @@ -1179,7 +1179,7 @@ const (
// TransferProcessorVisibilityArchivalTimeLimit is the upper time limit for archiving visibility records
// KeyName: history.transferProcessorVisibilityArchivalTimeLimit
// Value type: Duration
// Default value: 200ms (200*time.Millisecond)
// Default value: 400ms (400*time.Millisecond)
// Allowed filters: N/A
TransferProcessorVisibilityArchivalTimeLimit

Expand Down
4 changes: 2 additions & 2 deletions service/history/config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -436,7 +436,7 @@ func New(dc *dynamicconfig.Collection, numberOfShards int, storeType string, isA
TimerProcessorMaxRedispatchQueueSize: dc.GetIntProperty(dynamicconfig.TimerProcessorMaxRedispatchQueueSize, 10000),
TimerProcessorMaxTimeShift: dc.GetDurationProperty(dynamicconfig.TimerProcessorMaxTimeShift, 1*time.Second),
TimerProcessorHistoryArchivalSizeLimit: dc.GetIntProperty(dynamicconfig.TimerProcessorHistoryArchivalSizeLimit, 500*1024),
TimerProcessorArchivalTimeLimit: dc.GetDurationProperty(dynamicconfig.TimerProcessorArchivalTimeLimit, 1*time.Second),
TimerProcessorArchivalTimeLimit: dc.GetDurationProperty(dynamicconfig.TimerProcessorArchivalTimeLimit, 2*time.Second),

TransferTaskBatchSize: dc.GetIntProperty(dynamicconfig.TransferTaskBatchSize, 100),
TransferTaskDeleteBatchSize: dc.GetIntProperty(dynamicconfig.TransferTaskDeleteBatchSize, 4000),
Expand All @@ -454,7 +454,7 @@ func New(dc *dynamicconfig.Collection, numberOfShards int, storeType string, isA
TransferProcessorMaxRedispatchQueueSize: dc.GetIntProperty(dynamicconfig.TransferProcessorMaxRedispatchQueueSize, 10000),
TransferProcessorEnableValidator: dc.GetBoolProperty(dynamicconfig.TransferProcessorEnableValidator, false),
TransferProcessorValidationInterval: dc.GetDurationProperty(dynamicconfig.TransferProcessorValidationInterval, 30*time.Second),
TransferProcessorVisibilityArchivalTimeLimit: dc.GetDurationProperty(dynamicconfig.TransferProcessorVisibilityArchivalTimeLimit, 200*time.Millisecond),
TransferProcessorVisibilityArchivalTimeLimit: dc.GetDurationProperty(dynamicconfig.TransferProcessorVisibilityArchivalTimeLimit, 400*time.Millisecond),

CrossClusterTaskBatchSize: dc.GetIntProperty(dynamicconfig.CrossClusterTaskBatchSize, 100),
CrossClusterTaskDeleteBatchSize: dc.GetIntProperty(dynamicconfig.CrossClusterTaskDeleteBatchSize, 4000),
Expand Down

0 comments on commit 480c733

Please sign in to comment.