From 524e02e792302458d54e462d05b3e18be7b5a65b Mon Sep 17 00:00:00 2001 From: YangKeao Date: Thu, 15 Sep 2022 16:22:50 +0800 Subject: [PATCH] extend the staleness time for test Signed-off-by: YangKeao --- sessiontxn/staleread/processor_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/sessiontxn/staleread/processor_test.go b/sessiontxn/staleread/processor_test.go index 4a98bff0364fc..a60e66efa082d 100644 --- a/sessiontxn/staleread/processor_test.go +++ b/sessiontxn/staleread/processor_test.go @@ -142,12 +142,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() @@ -159,12 +159,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)