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 9b5d1fc + a534aa3 commit 5d35cdcCopy full SHA for 5d35cdc
pkg/ccl/changefeedccl/changefeed_test.go
@@ -11069,6 +11069,8 @@ func TestChangefeedKafkaMessageTooLarge(t *testing.T) {
11069
defer leaktest.AfterTest(t)()
11070
defer log.Scope(t).Close(t)
11071
11072
+ skip.UnderDuress(t, "prone to overload")
11073
+
11074
testFn := func(t *testing.T, s TestServer, f cdctest.TestFeedFactory) {
11075
if KafkaV2Enabled.Get(&s.Server.ClusterSettings().SV) {
11076
// This is already covered for the v2 sink in another test: TestKafkaSinkClientV2_Resize
0 commit comments