diff --git a/internal/otelarrow/test/e2e_test.go b/internal/otelarrow/test/e2e_test.go index 68bd8780a2d1..5ab64be914d7 100644 --- a/internal/otelarrow/test/e2e_test.go +++ b/internal/otelarrow/test/e2e_test.go @@ -680,6 +680,7 @@ func TestIntegrationAdmissionLimited(t *testing.T) { requestWhileTrue: func(test *testConsumer) bool { return test.sink.SpanCount() < 10000 }, + missingDeadline: true, } var ending func(*testing.T, testParams, *testConsumer, [][]ptrace.Traces) (_, _ map[string]int) @@ -712,12 +713,11 @@ func TestIntegrationAdmissionLimited(t *testing.T) { ecfg.Arrow.NumStreams = 10 - // Shorten timeouts for this test, because we intend - // for it to fail and don't want to wait for retries. - ecfg.TimeoutSettings.Timeout = 5 * time.Second - ecfg.RetryConfig.InitialInterval = 1 * time.Second - ecfg.RetryConfig.MaxInterval = 2 * time.Second - ecfg.RetryConfig.MaxElapsedTime = 10 * time.Second + // Disable export timeout and retry, + // because we expect progress to be + // slow for this test. + ecfg.TimeoutSettings.Timeout = 0 + ecfg.RetryConfig.Enabled = false ecfg.Arrow.MaxStreamLifetime = 5 * time.Second }, nearLimitGenFunc(), consumerFailure, ending) })