diff --git a/testbed/tests/log_test.go b/testbed/tests/log_test.go index 727fde8141ea..fc99c79d8588 100644 --- a/testbed/tests/log_test.go +++ b/testbed/tests/log_test.go @@ -386,13 +386,16 @@ func TestMemoryLimiterHit(t *testing.T) { otlpreceiver.WithTimeout(` timeout: 0s `) - processors := map[string]string{ - "memory_limiter": ` + processors := []ProcessorNameAndConfigBody{ + { + Name: "memory_limiter", + Body: ` memory_limiter: check_interval: 1s limit_mib: 300 spike_limit_mib: 150 `, + }, } ScenarioMemoryLimiterHit( t, @@ -402,6 +405,7 @@ func TestMemoryLimiterHit(t *testing.T) { DataItemsPerSecond: 100000, ItemsPerBatch: 1000, Parallel: 1, + MaxDelay: 20 * time.Second, }, performanceResultsSummary, 100, processors) } diff --git a/testbed/tests/scenarios.go b/testbed/tests/scenarios.go index 8a3d5f694662..600effce5e6a 100644 --- a/testbed/tests/scenarios.go +++ b/testbed/tests/scenarios.go @@ -559,7 +559,7 @@ func ScenarioMemoryLimiterHit( loadOptions testbed.LoadOptions, resultsSummary testbed.TestResultsSummary, sleepTime int, - processors map[string]string, + processors []ProcessorNameAndConfigBody, ) { resultDir, err := filepath.Abs(path.Join("results", t.Name())) require.NoError(t, err)