*: fix unstable test TestIndexMergeReaderClose (#43273)

close #43272
pingcap · Apr 21, 2023 · f8445e7 · f8445e7
1 parent f2760fb
commit f8445e7
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/executor/seqtest/seq_executor_test.go b/executor/seqtest/seq_executor_test.go
@@ -686,9 +686,15 @@ func TestIndexMergeReaderClose(t *testing.T) {
 	err := tk.QueryToErr("select /*+ USE_INDEX_MERGE(t, idx1, idx2) */ * from t where a > 10 or b < 100")
 	require.NoError(t, failpoint.Disable("github.com/pingcap/tidb/executor/startPartialIndexWorkerErr"))
 	require.Error(t, err)
-	require.False(t, checkGoroutineExists("fetchLoop"))
-	require.False(t, checkGoroutineExists("fetchHandles"))
-	require.False(t, checkGoroutineExists("waitPartialWorkersAndCloseFetchChan"))
+	require.Eventually(t, func() bool {
+		return !checkGoroutineExists("fetchLoop")
+	}, 5*time.Second, 100*time.Microsecond)
+	require.Eventually(t, func() bool {
+		return !checkGoroutineExists("fetchHandles")
+	}, 5*time.Second, 100*time.Microsecond)
+	require.Eventually(t, func() bool {
+		return !checkGoroutineExists("waitPartialWorkersAndCloseFetchChan")
+	}, 5*time.Second, 100*time.Microsecond)
 }
 
 func TestParallelHashAggClose(t *testing.T) {