From 22412254ac2c5953c9bf5ad2afda0fb33525adf5 Mon Sep 17 00:00:00 2001 From: Weizhen Wang Date: Thu, 29 Aug 2024 14:11:54 +0800 Subject: [PATCH] update Signed-off-by: Weizhen Wang --- statistics/handle/handle_hist_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/statistics/handle/handle_hist_test.go b/statistics/handle/handle_hist_test.go index 2167275cdf9c2..6189281d99c42 100644 --- a/statistics/handle/handle_hist_test.go +++ b/statistics/handle/handle_hist_test.go @@ -318,11 +318,11 @@ func TestRetry(t *testing.T) { result, err1 := h.HandleOneTask(task1, readerCtx, testKit.Session().(sqlexec.RestrictedSQLExecutor), exitCh) require.NoError(t, err1) require.Nil(t, result) - select { - case <-task1.ResultCh: - default: - t.Logf("task1.ResultCh should get nothing") - t.FailNow() + for _, resultCh := range stmtCtx1.StatsLoad.ResultCh { + rs1, ok1 := <-resultCh + require.True(t, rs1.Shared) + require.True(t, ok1) + require.Error(t, rs1.Val.(stmtctx.StatsLoadResult).Error) } require.NoError(t, failpoint.Disable("github.com/pingcap/tidb/statistics/handle/mockReadStatsForOneFail")) }