Skip to content

Commit

Permalink
test: fix unstable test TestStaleReadProcessorWithSelectTable (#37858)
Browse files Browse the repository at this point in the history
close #37228
  • Loading branch information
YangKeao authored Dec 8, 2022
1 parent 5348bb3 commit 7134b7b
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions sessiontxn/staleread/processor_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -152,12 +152,12 @@ func TestStaleReadProcessorWithSelectTable(t *testing.T) {
tk.MustExec("set @@tx_read_ts=''")

// `@@tidb_read_staleness`
tk.MustExec("set @@tidb_read_staleness=-5")
tk.MustExec("set @@tidb_read_staleness=-100")
processor = createProcessor(t, tk.Session())
err = processor.OnSelectTable(tn)
require.True(t, processor.IsStaleness())
require.Equal(t, int64(0), processor.GetStalenessInfoSchema().SchemaMetaVersion())
expectedTS, err := staleread.CalculateTsWithReadStaleness(tk.Session(), -5*time.Second)
expectedTS, err := staleread.CalculateTsWithReadStaleness(tk.Session(), -100*time.Second)
require.NoError(t, err)
require.Equal(t, expectedTS, processor.GetStalenessReadTS())
evaluator := processor.GetStalenessTSEvaluatorForPrepare()
Expand All @@ -169,12 +169,12 @@ func TestStaleReadProcessorWithSelectTable(t *testing.T) {
tk.MustExec("do sleep(0.01)")
evaluatorTS, err = evaluator(tk.Session())
require.NoError(t, err)
expectedTS2, err := staleread.CalculateTsWithReadStaleness(tk.Session(), -5*time.Second)
expectedTS2, err := staleread.CalculateTsWithReadStaleness(tk.Session(), -100*time.Second)
require.NoError(t, err)
require.Equal(t, expectedTS2, evaluatorTS)

// `@@tidb_read_staleness` will be ignored when `as of` or `@@tx_read_ts`
tk.MustExec("set @@tidb_read_staleness=-5")
tk.MustExec("set @@tidb_read_staleness=-100")
processor = createProcessor(t, tk.Session())
err = processor.OnSelectTable(p1.tn)
require.NoError(t, err)
Expand Down

0 comments on commit 7134b7b

Please sign in to comment.