File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -67,8 +67,8 @@ type PullerConfig struct {
6767
6868 // PendingRegionRequestQueueSize is the total size of the pending region request queue shared across
6969 // all puller workers connecting to a single TiKV store. This size is divided equally among all workers.
70- // For example, if PendingRegionRequestQueueSize is 256 and there are 8 workers connecting to the same store,
71- // each worker's queue size will be 256 / 8 = 32 .
70+ // For example, if PendingRegionRequestQueueSize is 32 and there are 8 workers connecting to the same store,
71+ // each worker's queue size will be 32 / 8 = 4 .
7272 PendingRegionRequestQueueSize int `toml:"pending-region-request-queue-size" json:"pending_region_request_queue_size"`
7373}
7474
@@ -78,7 +78,7 @@ func NewDefaultPullerConfig() *PullerConfig {
7878 EnableResolvedTsStuckDetection : false ,
7979 ResolvedTsStuckInterval : TomlDuration (5 * time .Minute ),
8080 LogRegionDetails : false ,
81- PendingRegionRequestQueueSize : 256 , // Base on test result
81+ PendingRegionRequestQueueSize : 32 , // This value is chosen to reduce the impact of new changefeeds on existing ones.
8282 }
8383}
8484
You can’t perform that action at this time.
0 commit comments