From 1da01ea10964bc44d573e886ff2c17958be4caf3 Mon Sep 17 00:00:00 2001 From: Ewan Chou Date: Mon, 7 May 2018 10:34:25 +0800 Subject: [PATCH] set GC worker and loadDeleteRangeSQL high priority (#6450) --- ddl/util/util.go | 2 +- store/tikv/gcworker/gc_worker.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ddl/util/util.go b/ddl/util/util.go index 3761356bceb95..042d6d4c54174 100644 --- a/ddl/util/util.go +++ b/ddl/util/util.go @@ -27,7 +27,7 @@ import ( ) const ( - loadDeleteRangeSQL = `SELECT job_id, element_id, start_key, end_key FROM mysql.gc_delete_range WHERE ts < %v ORDER BY ts` + loadDeleteRangeSQL = `SELECT HIGH_PRIORITY job_id, element_id, start_key, end_key FROM mysql.gc_delete_range WHERE ts < %v ORDER BY ts` completeDeleteRangeSQL = `DELETE FROM mysql.gc_delete_range WHERE job_id = %d AND element_id = %d` updateDeleteRangeSQL = `UPDATE mysql.gc_delete_range SET start_key = "%s" WHERE job_id = %d AND element_id = %d AND start_key = "%s"` ) diff --git a/store/tikv/gcworker/gc_worker.go b/store/tikv/gcworker/gc_worker.go index eacb0eff04df7..ef526d74eb50e 100644 --- a/store/tikv/gcworker/gc_worker.go +++ b/store/tikv/gcworker/gc_worker.go @@ -843,7 +843,7 @@ func (w *GCWorker) loadDurationWithDefault(key string, def time.Duration) (*time func (w *GCWorker) loadValueFromSysTable(key string, s session.Session) (string, error) { ctx := context.Background() - stmt := fmt.Sprintf(`SELECT (variable_value) FROM mysql.tidb WHERE variable_name='%s' FOR UPDATE`, key) + stmt := fmt.Sprintf(`SELECT HIGH_PRIORITY (variable_value) FROM mysql.tidb WHERE variable_name='%s' FOR UPDATE`, key) rs, err := s.Execute(ctx, stmt) if len(rs) > 0 { defer terror.Call(rs[0].Close)