This is an automated email from the ASF dual-hosted git repository. reta pushed a commit to branch 4.1.x-fixes in repository https://gitbox.apache.org/repos/asf/cxf.git
commit a9fe08d7c7fb1ef0ca3049def9da7e6b3d7be6ef Author: Guillaume Nodet <[email protected]> AuthorDate: Fri Mar 13 11:13:30 2026 +0100 Increase Awaitility timeout in tracing tests from 1s to 5s (#2962) The 1-second timeout in testThatNewSpanIsCreatedOnClientTimeout and similar tests is too tight for CI environments, causing flaky failures. Increase to 5 seconds to allow sufficient time for span collection while still catching genuine timeout issues. Co-authored-by: Claude Opus 4.6 <[email protected]> (cherry picked from commit 6d3209a3490419f0f5b386cd1e82b4103e49fb9a) --- .../cxf/systest/brave/jaxrs/AbstractBraveTracingTest.java | 6 +++--- .../cxf/systest/brave/jaxws/AbstractBraveTracingTest.java | 2 +- .../tracing/opentelemetry/OpenTelemetryTracingTest.java | 14 +++++++------- .../jaxrs/tracing/opentracing/OpenTracingTracingTest.java | 14 +++++++------- .../tracing/opentelemetry/OpenTelemetryTracingTest.java | 4 ++-- .../jaxws/tracing/opentracing/OpenTracingTracingTest.java | 4 ++-- 6 files changed, 22 insertions(+), 22 deletions(-) diff --git a/systests/tracing/src/test/java/org/apache/cxf/systest/brave/jaxrs/AbstractBraveTracingTest.java b/systests/tracing/src/test/java/org/apache/cxf/systest/brave/jaxrs/AbstractBraveTracingTest.java index 0a248da9e77..a7db3b275a7 100644 --- a/systests/tracing/src/test/java/org/apache/cxf/systest/brave/jaxrs/AbstractBraveTracingTest.java +++ b/systests/tracing/src/test/java/org/apache/cxf/systest/brave/jaxrs/AbstractBraveTracingTest.java @@ -265,7 +265,7 @@ public abstract class AbstractBraveTracingTest extends AbstractClientServerTestB } // Await till flush happens, usually a second is enough - await().atMost(Duration.ofSeconds(1L)).until(()-> TestSpanHandler.getAllSpans().size() == 4); + await().atMost(Duration.ofSeconds(5L)).until(()-> TestSpanHandler.getAllSpans().size() == 4); assertThat(TestSpanHandler.getAllSpans().size(), equalTo(4)); assertThat(TestSpanHandler.getAllSpans().get(3).name(), equalTo("test span")); @@ -292,7 +292,7 @@ public abstract class AbstractBraveTracingTest extends AbstractClientServerTestB } // Await till flush happens, usually a second is enough - await().atMost(Duration.ofSeconds(1L)).until(()-> TestSpanHandler.getAllSpans().size() == 4); + await().atMost(Duration.ofSeconds(5L)).until(()-> TestSpanHandler.getAllSpans().size() == 4); assertThat(TestSpanHandler.getAllSpans().size(), equalTo(4)); assertThat(TestSpanHandler.getAllSpans().get(3).name(), equalTo("test span")); @@ -340,7 +340,7 @@ public abstract class AbstractBraveTracingTest extends AbstractClientServerTestB try { client.get(); } finally { - await().atMost(Duration.ofSeconds(1L)).until(()-> TestSpanHandler.getAllSpans().size() == 2); + await().atMost(Duration.ofSeconds(5L)).until(()-> TestSpanHandler.getAllSpans().size() == 2); assertThat(TestSpanHandler.getAllSpans().size(), equalTo(2)); assertThat(TestSpanHandler.getAllSpans().get(0).name(), equalTo("GET " + client.getCurrentURI())); assertThat(TestSpanHandler.getAllSpans().get(0).tags(), hasKey("error")); diff --git a/systests/tracing/src/test/java/org/apache/cxf/systest/brave/jaxws/AbstractBraveTracingTest.java b/systests/tracing/src/test/java/org/apache/cxf/systest/brave/jaxws/AbstractBraveTracingTest.java index 07991044f4e..64f6ebbaba1 100644 --- a/systests/tracing/src/test/java/org/apache/cxf/systest/brave/jaxws/AbstractBraveTracingTest.java +++ b/systests/tracing/src/test/java/org/apache/cxf/systest/brave/jaxws/AbstractBraveTracingTest.java @@ -204,7 +204,7 @@ public abstract class AbstractBraveTracingTest extends AbstractClientServerTestB service.orderBooks(); // Await till flush happens, usually every second - await().atMost(Duration.ofSeconds(1L)).until(() -> TestSpanHandler.getAllSpans().size() == 2); + await().atMost(Duration.ofSeconds(5L)).until(() -> TestSpanHandler.getAllSpans().size() == 2); assertThat(TestSpanHandler.getAllSpans().get(0).name(), equalTo("POST /BookStore")); assertThat(TestSpanHandler.getAllSpans().get(1).name(), diff --git a/systests/tracing/src/test/java/org/apache/cxf/systest/jaxrs/tracing/opentelemetry/OpenTelemetryTracingTest.java b/systests/tracing/src/test/java/org/apache/cxf/systest/jaxrs/tracing/opentelemetry/OpenTelemetryTracingTest.java index dde899d4e2f..cc390ab0771 100644 --- a/systests/tracing/src/test/java/org/apache/cxf/systest/jaxrs/tracing/opentelemetry/OpenTelemetryTracingTest.java +++ b/systests/tracing/src/test/java/org/apache/cxf/systest/jaxrs/tracing/opentelemetry/OpenTelemetryTracingTest.java @@ -258,7 +258,7 @@ public class OpenTelemetryTracingTest extends AbstractClientServerTestBase { final Response r = withTrace(createWebClient("/bookstore/books/async")).get(); assertEquals(Status.OK.getStatusCode(), r.getStatus()); - await().atMost(Duration.ofSeconds(1L)).until(() -> otelRule.getSpans().size() == 2); + await().atMost(Duration.ofSeconds(5L)).until(() -> otelRule.getSpans().size() == 2); final List<SpanData> spans = getSpansSorted(); assertThat(spans.size(), equalTo(2)); @@ -288,7 +288,7 @@ public class OpenTelemetryTracingTest extends AbstractClientServerTestBase { final Response r = createWebClient("/bookstore/books/async").get(); assertEquals(Status.OK.getStatusCode(), r.getStatus()); - await().atMost(Duration.ofSeconds(1L)).until(() -> otelRule.getSpans().size() == 2); + await().atMost(Duration.ofSeconds(5L)).until(() -> otelRule.getSpans().size() == 2); final List<SpanData> spans = getSpansSorted(); assertThat(spans.size(), equalTo(2)); @@ -304,7 +304,7 @@ public class OpenTelemetryTracingTest extends AbstractClientServerTestBase { final Response r = client.async().get().get(1L, TimeUnit.SECONDS); assertEquals(Status.OK.getStatusCode(), r.getStatus()); - await().atMost(Duration.ofSeconds(1L)).until(() -> otelRule.getSpans().size() == 3); + await().atMost(Duration.ofSeconds(5L)).until(() -> otelRule.getSpans().size() == 3); assertThat(otelRule.getSpans().size(), equalTo(3)); assertThat(otelRule.getSpans().get(0).getName(), equalTo("Get Books")); @@ -374,7 +374,7 @@ public class OpenTelemetryTracingTest extends AbstractClientServerTestBase { } // Await till flush happens, usually every second - await().atMost(Duration.ofSeconds(1L)).until(() -> otelRule.getSpans().size() == 4); + await().atMost(Duration.ofSeconds(5L)).until(() -> otelRule.getSpans().size() == 4); assertThat(otelRule.getSpans().size(), equalTo(4)); assertThat(otelRule.getSpans().get(3).getName(), equalTo("test span")); @@ -393,7 +393,7 @@ public class OpenTelemetryTracingTest extends AbstractClientServerTestBase { assertThat(Span.current().getSpanContext().getSpanId(), equalTo(span.getSpanContext().getSpanId())); - await().atMost(Duration.ofSeconds(1L)).until(() -> otelRule.getSpans().size() == 3); + await().atMost(Duration.ofSeconds(5L)).until(() -> otelRule.getSpans().size() == 3); assertThat(otelRule.getSpans().size(), equalTo(3)); assertThat(otelRule.getSpans().get(0).getName(), equalTo("Get Books")); @@ -407,7 +407,7 @@ public class OpenTelemetryTracingTest extends AbstractClientServerTestBase { } // Await till flush happens, usually every second - await().atMost(Duration.ofSeconds(1L)).until(() -> otelRule.getSpans().size() == 4); + await().atMost(Duration.ofSeconds(5L)).until(() -> otelRule.getSpans().size() == 4); assertThat(otelRule.getSpans().size(), equalTo(4)); assertThat(otelRule.getSpans().get(3).getName(), equalTo("test span")); @@ -444,7 +444,7 @@ public class OpenTelemetryTracingTest extends AbstractClientServerTestBase { try { client.get(); } finally { - await().atMost(Duration.ofSeconds(1L)).until(() -> otelRule.getSpans().size() == 2); + await().atMost(Duration.ofSeconds(5L)).until(() -> otelRule.getSpans().size() == 2); assertThat(otelRule.getSpans().toString(), otelRule.getSpans().size(), equalTo(2)); assertThat(otelRule.getSpans().get(0).getName(), equalTo("GET " + client.getCurrentURI())); assertThat(otelRule.getSpans().get(0).getStatus().getStatusCode(), equalTo(StatusCode.ERROR)); diff --git a/systests/tracing/src/test/java/org/apache/cxf/systest/jaxrs/tracing/opentracing/OpenTracingTracingTest.java b/systests/tracing/src/test/java/org/apache/cxf/systest/jaxrs/tracing/opentracing/OpenTracingTracingTest.java index d8be95bbd6e..367247d13ba 100644 --- a/systests/tracing/src/test/java/org/apache/cxf/systest/jaxrs/tracing/opentracing/OpenTracingTracingTest.java +++ b/systests/tracing/src/test/java/org/apache/cxf/systest/jaxrs/tracing/opentracing/OpenTracingTracingTest.java @@ -200,7 +200,7 @@ public class OpenTracingTracingTest extends AbstractClientServerTestBase { final Response r = withTrace(createWebClient("/bookstore/books/async"), spanId).get(); assertEquals(Status.OK.getStatusCode(), r.getStatus()); - await().atMost(Duration.ofSeconds(1L)).until(()-> REPORTER.getSpans().size() == 2); + await().atMost(Duration.ofSeconds(5L)).until(()-> REPORTER.getSpans().size() == 2); final List<JaegerSpan> spans = getSpansSorted(); assertThat(spans.size(), equalTo(2)); @@ -227,7 +227,7 @@ public class OpenTracingTracingTest extends AbstractClientServerTestBase { final Response r = createWebClient("/bookstore/books/async").get(); assertEquals(Status.OK.getStatusCode(), r.getStatus()); - await().atMost(Duration.ofSeconds(1L)).until(()-> REPORTER.getSpans().size() == 2); + await().atMost(Duration.ofSeconds(5L)).until(()-> REPORTER.getSpans().size() == 2); final List<JaegerSpan> spans = getSpansSorted(); assertThat(spans.size(), equalTo(2)); @@ -242,7 +242,7 @@ public class OpenTracingTracingTest extends AbstractClientServerTestBase { final Response r = client.async().get().get(1L, TimeUnit.SECONDS); assertEquals(Status.OK.getStatusCode(), r.getStatus()); - await().atMost(Duration.ofSeconds(1L)).until(()-> REPORTER.getSpans().size() == 3); + await().atMost(Duration.ofSeconds(5L)).until(()-> REPORTER.getSpans().size() == 3); assertThat(REPORTER.getSpans().size(), equalTo(3)); assertThat(REPORTER.getSpans().get(0).getOperationName(), equalTo("Get Books")); @@ -326,7 +326,7 @@ public class OpenTracingTracingTest extends AbstractClientServerTestBase { } // Await till flush happens, usually every second - await().atMost(Duration.ofSeconds(1L)).until(()-> REPORTER.getSpans().size() == 4); + await().atMost(Duration.ofSeconds(5L)).until(()-> REPORTER.getSpans().size() == 4); assertThat(REPORTER.getSpans().size(), equalTo(4)); assertThat(REPORTER.getSpans().get(3).getOperationName(), equalTo("test span")); @@ -343,7 +343,7 @@ public class OpenTracingTracingTest extends AbstractClientServerTestBase { assertEquals(Status.OK.getStatusCode(), r.getStatus()); assertThat(tracer.activeSpan().context(), equalTo(span.context())); - await().atMost(Duration.ofSeconds(1L)).until(()-> REPORTER.getSpans().size() == 3); + await().atMost(Duration.ofSeconds(5L)).until(()-> REPORTER.getSpans().size() == 3); assertThat(REPORTER.getSpans().size(), equalTo(3)); assertThat(REPORTER.getSpans().get(0).getOperationName(), equalTo("Get Books")); @@ -357,7 +357,7 @@ public class OpenTracingTracingTest extends AbstractClientServerTestBase { } // Await till flush happens, usually every second - await().atMost(Duration.ofSeconds(1L)).until(()-> REPORTER.getSpans().size() == 4); + await().atMost(Duration.ofSeconds(5L)).until(()-> REPORTER.getSpans().size() == 4); assertThat(REPORTER.getSpans().size(), equalTo(4)); assertThat(REPORTER.getSpans().get(3).getOperationName(), equalTo("test span")); @@ -392,7 +392,7 @@ public class OpenTracingTracingTest extends AbstractClientServerTestBase { try { client.get(); } finally { - await().atMost(Duration.ofSeconds(1L)).until(()-> REPORTER.getSpans().size() == 2); + await().atMost(Duration.ofSeconds(5L)).until(()-> REPORTER.getSpans().size() == 2); assertThat(REPORTER.getSpans().toString(), REPORTER.getSpans().size(), equalTo(2)); assertThat(REPORTER.getSpans().get(0).getOperationName(), equalTo("GET " + client.getCurrentURI())); assertThat(REPORTER.getSpans().get(0).getTags(), hasItem(Tags.ERROR.getKey(), Boolean.TRUE)); diff --git a/systests/tracing/src/test/java/org/apache/cxf/systest/jaxws/tracing/opentelemetry/OpenTelemetryTracingTest.java b/systests/tracing/src/test/java/org/apache/cxf/systest/jaxws/tracing/opentelemetry/OpenTelemetryTracingTest.java index 71a9f499e2f..295ae79fd79 100644 --- a/systests/tracing/src/test/java/org/apache/cxf/systest/jaxws/tracing/opentelemetry/OpenTelemetryTracingTest.java +++ b/systests/tracing/src/test/java/org/apache/cxf/systest/jaxws/tracing/opentelemetry/OpenTelemetryTracingTest.java @@ -247,7 +247,7 @@ public class OpenTelemetryTracingTest extends AbstractClientServerTestBase { } // Await till flush happens, usually every second - await().atMost(Duration.ofSeconds(1L)).until(() -> otelRule.getSpans().size() == 4); + await().atMost(Duration.ofSeconds(5L)).until(() -> otelRule.getSpans().size() == 4); assertThat(otelRule.getSpans().size(), equalTo(4)); assertThat(otelRule.getSpans().get(3).getName(), equalTo("test span")); @@ -331,7 +331,7 @@ public class OpenTelemetryTracingTest extends AbstractClientServerTestBase { service.orderBooks(); // Await till flush happens, usually every second - await().atMost(Duration.ofSeconds(1L)).until(() -> otelRule.getSpans().size() == 2); + await().atMost(Duration.ofSeconds(5L)).until(() -> otelRule.getSpans().size() == 2); assertThat(otelRule.getSpans().get(0).getName(), equalTo("POST /BookStore")); assertThat(otelRule.getSpans().get(1).getName(), diff --git a/systests/tracing/src/test/java/org/apache/cxf/systest/jaxws/tracing/opentracing/OpenTracingTracingTest.java b/systests/tracing/src/test/java/org/apache/cxf/systest/jaxws/tracing/opentracing/OpenTracingTracingTest.java index c5ff413c2ad..bdbdceb6f06 100644 --- a/systests/tracing/src/test/java/org/apache/cxf/systest/jaxws/tracing/opentracing/OpenTracingTracingTest.java +++ b/systests/tracing/src/test/java/org/apache/cxf/systest/jaxws/tracing/opentracing/OpenTracingTracingTest.java @@ -178,7 +178,7 @@ public class OpenTracingTracingTest extends AbstractClientServerTestBase { } // Await till flush happens, usually every second - await().atMost(Duration.ofSeconds(1L)).until(()-> REPORTER.getSpans().size() == 4); + await().atMost(Duration.ofSeconds(5L)).until(()-> REPORTER.getSpans().size() == 4); assertThat(REPORTER.getSpans().size(), equalTo(4)); assertThat(REPORTER.getSpans().get(3).getOperationName(), equalTo("test span")); @@ -234,7 +234,7 @@ public class OpenTracingTracingTest extends AbstractClientServerTestBase { service.orderBooks(); // Await till flush happens, usually every second - await().atMost(Duration.ofSeconds(1L)).until(() -> REPORTER.getSpans().size() == 2); + await().atMost(Duration.ofSeconds(5L)).until(() -> REPORTER.getSpans().size() == 2); assertThat(REPORTER.getSpans().get(0).getOperationName(), equalTo("POST /BookStore")); assertThat(REPORTER.getSpans().get(1).getOperationName(),
