From da38aaea194f62ffece1bb522c79bd74b4de38dd Mon Sep 17 00:00:00 2001
From: Dan Jaglowski <jaglows3@gmail.com>
Date: Wed, 4 May 2022 11:04:12 -0400
Subject: [PATCH] [testbed/Carbon] Skip flaky test

---
 testbed/tests/metric_test.go | 45 ++++++++++++++++++++----------------
 1 file changed, 25 insertions(+), 20 deletions(-)

diff --git a/testbed/tests/metric_test.go b/testbed/tests/metric_test.go
index 3533e8f4d81e..77484316d7f1 100644
--- a/testbed/tests/metric_test.go
+++ b/testbed/tests/metric_test.go
@@ -36,48 +36,50 @@ func TestMetric10kDPS(t *testing.T) {
 		sender       testbed.DataSender
 		receiver     testbed.DataReceiver
 		resourceSpec testbed.ResourceSpec
+		skipMessage  string
 	}{
 		{
-			"Carbon",
-			datasenders.NewCarbonDataSender(testbed.GetAvailablePort(t)),
-			datareceivers.NewCarbonDataReceiver(testbed.GetAvailablePort(t)),
-			testbed.ResourceSpec{
+			name:     "Carbon",
+			sender:   datasenders.NewCarbonDataSender(testbed.GetAvailablePort(t)),
+			receiver: datareceivers.NewCarbonDataReceiver(testbed.GetAvailablePort(t)),
+			resourceSpec: testbed.ResourceSpec{
 				ExpectedMaxCPU: 237,
 				ExpectedMaxRAM: 100,
 			},
+			skipMessage: "Flaky test, https://github.com/open-telemetry/opentelemetry-collector-contrib/issues/9729",
 		},
 		{
-			"OpenCensus",
-			datasenders.NewOCMetricDataSender(testbed.DefaultHost, testbed.GetAvailablePort(t)),
-			datareceivers.NewOCDataReceiver(testbed.GetAvailablePort(t)),
-			testbed.ResourceSpec{
+			name:     "OpenCensus",
+			sender:   datasenders.NewOCMetricDataSender(testbed.DefaultHost, testbed.GetAvailablePort(t)),
+			receiver: datareceivers.NewOCDataReceiver(testbed.GetAvailablePort(t)),
+			resourceSpec: testbed.ResourceSpec{
 				ExpectedMaxCPU: 85,
 				ExpectedMaxRAM: 100,
 			},
 		},
 		{
-			"OTLP",
-			testbed.NewOTLPMetricDataSender(testbed.DefaultHost, testbed.GetAvailablePort(t)),
-			testbed.NewOTLPDataReceiver(testbed.GetAvailablePort(t)),
-			testbed.ResourceSpec{
+			name:     "OTLP",
+			sender:   testbed.NewOTLPMetricDataSender(testbed.DefaultHost, testbed.GetAvailablePort(t)),
+			receiver: testbed.NewOTLPDataReceiver(testbed.GetAvailablePort(t)),
+			resourceSpec: testbed.ResourceSpec{
 				ExpectedMaxCPU: 60,
 				ExpectedMaxRAM: 105,
 			},
 		},
 		{
-			"OTLP-HTTP",
-			testbed.NewOTLPHTTPMetricDataSender(testbed.DefaultHost, testbed.GetAvailablePort(t)),
-			testbed.NewOTLPHTTPDataReceiver(testbed.GetAvailablePort(t)),
-			testbed.ResourceSpec{
+			name:     "OTLP-HTTP",
+			sender:   testbed.NewOTLPHTTPMetricDataSender(testbed.DefaultHost, testbed.GetAvailablePort(t)),
+			receiver: testbed.NewOTLPHTTPDataReceiver(testbed.GetAvailablePort(t)),
+			resourceSpec: testbed.ResourceSpec{
 				ExpectedMaxCPU: 60,
 				ExpectedMaxRAM: 100,
 			},
 		},
 		{
-			"SignalFx",
-			datasenders.NewSFxMetricDataSender(testbed.GetAvailablePort(t)),
-			datareceivers.NewSFxMetricsDataReceiver(testbed.GetAvailablePort(t)),
-			testbed.ResourceSpec{
+			name:     "SignalFx",
+			sender:   datasenders.NewSFxMetricDataSender(testbed.GetAvailablePort(t)),
+			receiver: datareceivers.NewSFxMetricsDataReceiver(testbed.GetAvailablePort(t)),
+			resourceSpec: testbed.ResourceSpec{
 				ExpectedMaxCPU: 120,
 				ExpectedMaxRAM: 98,
 			},
@@ -86,6 +88,9 @@ func TestMetric10kDPS(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
+			if test.skipMessage != "" {
+				t.Skip(test.skipMessage)
+			}
 			Scenario10kItemsPerSecond(
 				t,
 				test.sender,