We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents d74060c + 332e188 commit e71acdfCopy full SHA for e71acdf
pkg/ccl/changefeedccl/changefeed_test.go
@@ -10459,6 +10459,8 @@ func TestChangefeedKafkaMessageTooLarge(t *testing.T) {
10459
defer leaktest.AfterTest(t)()
10460
defer log.Scope(t).Close(t)
10461
10462
+ skip.UnderDuress(t, "prone to overload")
10463
+
10464
testFn := func(t *testing.T, s TestServer, f cdctest.TestFeedFactory) {
10465
if KafkaV2Enabled.Get(&s.Server.ClusterSettings().SV) {
10466
// This is already covered for the v2 sink in another test: TestKafkaSinkClientV2_Resize
0 commit comments