Skip to content

Commit d94eca5

Browse files
committed
changefeedccl: skip TestChangefeedKafkaMessageTooLarge under duress
Closes #155333 Release note: None
1 parent f13dea2 commit d94eca5

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pkg/ccl/changefeedccl/changefeed_test.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11041,6 +11041,8 @@ func TestChangefeedKafkaMessageTooLarge(t *testing.T) {
1104111041
defer leaktest.AfterTest(t)()
1104211042
defer log.Scope(t).Close(t)
1104311043

11044+
skip.UnderDuress(t, "prone to overload")
11045+
1104411046
testFn := func(t *testing.T, s TestServer, f cdctest.TestFeedFactory) {
1104511047
if KafkaV2Enabled.Get(&s.Server.ClusterSettings().SV) {
1104611048
// This is already covered for the v2 sink in another test: TestKafkaSinkClientV2_Resize

0 commit comments

Comments
 (0)