diff --git a/pkg/ttl/cache/ttlstatus_test.go b/pkg/ttl/cache/ttlstatus_test.go index d7a6697546868..3c6c1a73d5329 100644 --- a/pkg/ttl/cache/ttlstatus_test.go +++ b/pkg/ttl/cache/ttlstatus_test.go @@ -169,13 +169,17 @@ func TestTTLStatusCache(t *testing.T) { } for index, testCase := range testCases { t.Run(testCase.columnName, func(t *testing.T) { + tk.MustExec("delete from mysql.tidb_ttl_table_status") sql := fmt.Sprintf(`insert into mysql.tidb_ttl_table_status (table_id, %s) values (%d, %s)`, testCase.columnName, index, testCase.sqlLiteral) tk.MustExec(sql) assert.NoError(t, isc.Update(context.Background(), ttlSession)) - assert.Equal(t, index+1, len(isc.Tables)) - testCase.assert(isc.Tables[int64(index)]) + assert.Len(t, isc.Tables, 1) + table := isc.Tables[int64(index)] + if assert.NotNil(t, table) { + testCase.assert(table) + } }) } }