Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

ddl: reduce the interval for checking "create table/schema" #7608

Merged
merged 7 commits into from
Sep 12, 2018
Merged

ddl: reduce the interval for checking "create table/schema" #7608

Changes from 3 commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
6a25b35
ddl: update create table interval
zimulala Sep 4, 2018
f529324
ddl: update a comment
zimulala Sep 4, 2018
07de43b
ddl: address comments
zimulala Sep 11, 2018
a1578b8
Merge branch 'master' into create-table-interval
zimulala Sep 11, 2018
430d9ff
Merge branch 'master' into create-table-interval
zz-jason Sep 12, 2018
e2aea2d
Merge branch 'master' into create-table-interval
zz-jason Sep 12, 2018
331e744
Merge branch 'master' into create-table-interval
zz-jason Sep 12, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 4 additions & 1 deletion ddl/ddl.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -447,6 +447,9 @@ func checkJobMaxInterval(job *model.Job) time.Duration {
if job.Type == model.ActionAddIndex {
return 3 * time.Second
}
if job.Type == model.ActionCreateTable || job.Type == model.ActionCreateSchema {
return 500 * time.Millisecond
}
return 1 * time.Second
}

Expand Down Expand Up @@ -484,7 +487,7 @@ func (d *ddl) doDDLJob(ctx sessionctx.Context, job *model.Job) error {
jobID := job.ID
// For a job from start to end, the state of it will be none -> delete only -> write only -> reorganization -> public
// For every state changes, we will wait as lease 2 * lease time, so here the ticker check is 10 * lease.
// But we use etcd to speed up, normally it takes less than 1s now, so we use 1s or 3s as the max value.
// But we use etcd to speed up, normally it takes less than 0.5s now, so we use 0.5s or 1s or 3s as the max value.
ticker := time.NewTicker(chooseLeaseTime(10*d.lease, checkJobMaxInterval(job)))
startTime := time.Now()
metrics.JobsGauge.WithLabelValues(job.Type.String()).Inc()
Expand Down