Skip to content

Commit a534aa3

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

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
@@ -11069,6 +11069,8 @@ func TestChangefeedKafkaMessageTooLarge(t *testing.T) {
1106911069
defer leaktest.AfterTest(t)()
1107011070
defer log.Scope(t).Close(t)
1107111071

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

0 commit comments

Comments
 (0)