Skip to content

Commit

Permalink
store/tikv: enlarge default committer-concurrency to avoid queuing (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
youjiali1995 authored Mar 31, 2021
1 parent b8b5151 commit f64856b
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion config/config.toml.example
Original file line number Diff line number Diff line change
Expand Up @@ -286,7 +286,7 @@ txn-total-size-limit = 104857600
txn-entry-size-limit = 6291456

# The max number of running concurrency two phase committer request for an SQL.
committer-concurrency = 16
committer-concurrency = 128

# max lifetime of transaction ttl manager.
max-txn-ttl = 3600000
Expand Down
2 changes: 1 addition & 1 deletion metrics/grafana/tidb.json
Original file line number Diff line number Diff line change
Expand Up @@ -3855,7 +3855,7 @@
},
"yaxes": [
{
"format": "s",
"format": "ns",
"label": null,
"logBase": 2,
"max": null,
Expand Down
2 changes: 1 addition & 1 deletion store/tikv/2pc.go
Original file line number Diff line number Diff line change
Expand Up @@ -1644,7 +1644,7 @@ func (batchExe *batchExecutor) process(batches []batchMutations) error {
}
}
close(exitCh)
metrics.TiKVTokenWaitDuration.Observe(batchExe.tokenWaitDuration.Seconds())
metrics.TiKVTokenWaitDuration.Observe(float64(batchExe.tokenWaitDuration.Nanoseconds()))
return err
}

Expand Down
2 changes: 1 addition & 1 deletion store/tikv/config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ type Config struct {
// DefaultConfig returns the default configuration.
func DefaultConfig() Config {
return Config{
CommitterConcurrency: 16,
CommitterConcurrency: 128,
MaxTxnTTL: 60 * 60 * 1000, // 1hour
ServerMemoryQuota: 0,
TiKVClient: DefaultTiKVClient(),
Expand Down

0 comments on commit f64856b

Please sign in to comment.