Skip to content

Commit

Permalink
executor: change ut parameters in parallel aggregate hash spill ut (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
xzhangxian1008 authored Feb 6, 2024
1 parent 5c95f3b commit f7aaf1c
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pkg/executor/aggregate/agg_spill_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -347,8 +347,8 @@ func TestGetCorrectResult(t *testing.T) {
ctx := mock.NewContext()
initCtx(ctx, newRootExceedAction, hardLimitBytesNum, 256)

rowNum := 100000 + rand.Intn(100000)
ndv := 50000 + rand.Intn(50000)
rowNum := 100000
ndv := 50000
col1, col2 := generateData(rowNum, ndv)
result := generateResult(col1, col2)
opt := getMockDataSourceParameters(ctx)
Expand Down Expand Up @@ -378,9 +378,9 @@ func TestGetCorrectResult(t *testing.T) {
executeCorrecResultTest(t, ctx, aggExec, dataSource, result)
}

require.Equal(t, 0, newRootExceedAction.GetTriggeredNum())
finished.Store(true)
wg.Wait()
require.NoError(t, failpoint.Disable("github.com/pingcap/tidb/pkg/executor/aggregate/slowSomePartialWorkers"))
}

func TestFallBackAction(t *testing.T) {
Expand Down

0 comments on commit f7aaf1c

Please sign in to comment.