From f7aaf1cfa16d28fb9a075448af39314f70d5506d Mon Sep 17 00:00:00 2001 From: xzhangxian1008 Date: Tue, 6 Feb 2024 19:16:15 +0800 Subject: [PATCH] executor: change ut parameters in parallel aggregate hash spill ut (#51012) ref pingcap/tidb#47733 --- pkg/executor/aggregate/agg_spill_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/executor/aggregate/agg_spill_test.go b/pkg/executor/aggregate/agg_spill_test.go index b94e21000a565..731d4c7324679 100644 --- a/pkg/executor/aggregate/agg_spill_test.go +++ b/pkg/executor/aggregate/agg_spill_test.go @@ -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) @@ -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) {