Skip to content

Commit 2d091f5

Browse files
committed
remove show changefeeds poller
1 parent 5bbc969 commit 2d091f5

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

pkg/cmd/roachtest/tests/jobs.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -120,9 +120,9 @@ func runJobsStress(ctx context.Context, t test.Test, c cluster.Cluster) {
120120
}
121121
}
122122
}
123-
for i := 0; i < nodeCount; i++ {
124-
group.Go(randomPoller(time.Second, checkJobQueryLatency))
125-
}
123+
//for i := 0; i < nodeCount; i++ {
124+
// group.Go(randomPoller(time.Second, checkJobQueryLatency))
125+
//}
126126

127127
waitTime := time.Duration(rng.Intn(pollerMinFrequencySeconds)+1) * time.Second
128128
jobIDToTableName := make(map[jobspb.JobID]string)
@@ -145,6 +145,7 @@ func runJobsStress(ctx context.Context, t test.Test, c cluster.Cluster) {
145145

146146
require.NoError(t, group.WaitE())
147147
checkJobSystemHealth(ctx, t, c, rng)
148+
require.NoError(t, checkJobQueryLatency(ctx, t, c, rng))
148149
}
149150

150151
func createTablesWithChangefeeds(

0 commit comments

Comments
 (0)