@@ -152,12 +152,12 @@ func TestStaleReadProcessorWithSelectTable(t *testing.T) {
152
152
tk .MustExec ("set @@tx_read_ts=''" )
153
153
154
154
// `@@tidb_read_staleness`
155
- tk .MustExec ("set @@tidb_read_staleness=-5 " )
155
+ tk .MustExec ("set @@tidb_read_staleness=-100 " )
156
156
processor = createProcessor (t , tk .Session ())
157
157
err = processor .OnSelectTable (tn )
158
158
require .True (t , processor .IsStaleness ())
159
159
require .Equal (t , int64 (0 ), processor .GetStalenessInfoSchema ().SchemaMetaVersion ())
160
- expectedTS , err := staleread .CalculateTsWithReadStaleness (tk .Session (), - 5 * time .Second )
160
+ expectedTS , err := staleread .CalculateTsWithReadStaleness (tk .Session (), - 100 * time .Second )
161
161
require .NoError (t , err )
162
162
require .Equal (t , expectedTS , processor .GetStalenessReadTS ())
163
163
evaluator := processor .GetStalenessTSEvaluatorForPrepare ()
@@ -169,12 +169,12 @@ func TestStaleReadProcessorWithSelectTable(t *testing.T) {
169
169
tk .MustExec ("do sleep(0.01)" )
170
170
evaluatorTS , err = evaluator (tk .Session ())
171
171
require .NoError (t , err )
172
- expectedTS2 , err := staleread .CalculateTsWithReadStaleness (tk .Session (), - 5 * time .Second )
172
+ expectedTS2 , err := staleread .CalculateTsWithReadStaleness (tk .Session (), - 100 * time .Second )
173
173
require .NoError (t , err )
174
174
require .Equal (t , expectedTS2 , evaluatorTS )
175
175
176
176
// `@@tidb_read_staleness` will be ignored when `as of` or `@@tx_read_ts`
177
- tk .MustExec ("set @@tidb_read_staleness=-5 " )
177
+ tk .MustExec ("set @@tidb_read_staleness=-100 " )
178
178
processor = createProcessor (t , tk .Session ())
179
179
err = processor .OnSelectTable (p1 .tn )
180
180
require .NoError (t , err )
0 commit comments