Skip to content

Commit 0d92408

Browse files
craig[bot]aerfrei
andcommitted
Merge #152689
152689: changefeedccl: fix test flake by waiting for rangefeed start r=andyyang890 a=aerfrei Previously, this test would flake because a table that we were asserting the admin user could see hadn't yet become visible. Now we assert the changefeed and rangefeed have started by waiting for a highwater mark. Epic: none Fixes: #152060 Release note: None Co-authored-by: Aerin Freilich <[email protected]>
2 parents ee0bb8f + 9f48bed commit 0d92408

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

pkg/ccl/changefeedccl/changefeed_test.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9583,8 +9583,6 @@ func TestDistSenderRangeFeedPopulatesVirtualTable(t *testing.T) {
95839583
defer leaktest.AfterTest(t)()
95849584
defer log.Scope(t).Close(t)
95859585

9586-
skip.WithIssue(t, 152060)
9587-
95889586
scanner := keysutil.MakePrettyScanner(nil, nil)
95899587

95909588
observeTables := func(sqlDB *sqlutils.SQLRunner, codec keys.SQLCodec) []int {
@@ -9628,6 +9626,10 @@ func TestDistSenderRangeFeedPopulatesVirtualTable(t *testing.T) {
96289626
})
96299627
defer closeFeed(t, cf)
96309628

9629+
// We need to ensure that the reason the user doesn't see the table
9630+
// is not because the rangefeed hasn't started yet.
9631+
waitForHighwater(t, cf.(cdctest.EnterpriseTestFeed), s.Server.JobRegistry().(*jobs.Registry))
9632+
96319633
for _, c := range cases {
96329634
testutils.SucceedsSoon(t, func() error {
96339635
asUser(t, f, c.user, func(userDB *sqlutils.SQLRunner) {

0 commit comments

Comments
 (0)