Skip to content

Commit 44a5cef

Browse files
committed
update
1 parent 48c4120 commit 44a5cef

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

ttl/ttlworker/job_manager.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ const taskGCTemplate = `DELETE task FROM
5858
ON task.job_id = job.current_job_id
5959
WHERE job.table_id IS NULL`
6060

61-
const ttlJobHistoryGCTemplate = `DELETE FROM mysql.tidb_ttl_job_history WHERE create_time < CURDATE() - INTERVAL 30 DAY`
61+
const ttlJobHistoryGCTemplate = `DELETE FROM mysql.tidb_ttl_job_history WHERE create_time < CURDATE() - INTERVAL 90 DAY`
6262

6363
const timeFormat = "2006-01-02 15:04:05"
6464

ttl/ttlworker/job_manager_integration_test.go

+7-5
Original file line numberDiff line numberDiff line change
@@ -558,11 +558,13 @@ func TestGCTTLHistory(t *testing.T) {
558558
}
559559

560560
addHistory(1, 1)
561-
addHistory(2, 29)
562-
addHistory(3, 30)
563-
addHistory(4, 31)
564-
addHistory(5, 32)
561+
addHistory(2, 30)
562+
addHistory(3, 60)
563+
addHistory(4, 89)
564+
addHistory(5, 90)
565+
addHistory(6, 91)
566+
addHistory(7, 100)
565567
se := session.NewSession(tk.Session(), tk.Session(), func(_ session.Session) {})
566568
ttlworker.DoGC(context.TODO(), se)
567-
tk.MustQuery("select job_id from mysql.tidb_ttl_job_history order by job_id asc").Check(testkit.Rows("1", "2", "3"))
569+
tk.MustQuery("select job_id from mysql.tidb_ttl_job_history order by job_id asc").Check(testkit.Rows("1", "2", "3", "4", "5"))
568570
}

0 commit comments

Comments
 (0)