From 918de91f2364b5d47beb97f6b08142031481023b Mon Sep 17 00:00:00 2001 From: flaky-claw Date: Fri, 24 Jul 2026 09:33:04 +0000 Subject: [PATCH] fix: stabilize flaky issue #67741 --- br/pkg/streamhelper/subscription_test.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/br/pkg/streamhelper/subscription_test.go b/br/pkg/streamhelper/subscription_test.go index 4183fd3cea05f..bc4256dc17f79 100644 --- a/br/pkg/streamhelper/subscription_test.go +++ b/br/pkg/streamhelper/subscription_test.go @@ -114,12 +114,8 @@ func TestNormalError(t *testing.T) { cp = c.advanceCheckpoints() c.flushAll() } - waitPendingEvents(t, sub) + s := collectCheckpointSpans(t, sub, cp) sub.Drop() - s := spans.Sorted(spans.NewFullWith(spans.Full(), 1)) - for k := range sub.Events() { - s.Merge(k) - } req.Equal(cp, s.MinValue(), "%d vs %d", cp, s.MinValue()) }