From 09cace6f005cca8717f6e4d6a41c96ad19c6c6e3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aur=C3=A9lien=20Pupier?= Date: Fri, 18 Sep 2026 10:38:16 +0200 Subject: [PATCH] CAMEL-24787 - reduce flakiness of Cassandra Integration tests MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit there is regularly this stack: ``` com.datastax.oss.driver.api.core.DriverTimeoutException: Query timed out after PT5S at com.datastax.oss.driver.api.core.DriverTimeoutException.copy(DriverTimeoutException.java:36) at com.datastax.oss.driver.internal.core.util.concurrent.CompletableFutures.getUninterruptibly(CompletableFutures.java:154) at com.datastax.oss.driver.internal.core.cql.CqlRequestSyncProcessor.process(CqlRequestSyncProcessor.java:55) at com.datastax.oss.driver.internal.core.cql.CqlRequestSyncProcessor.process(CqlRequestSyncProcessor.java:32) at com.datastax.oss.driver.internal.core.session.DefaultSession.execute(DefaultSession.java:234) at com.datastax.oss.driver.api.core.cql.SyncCqlSession.execute(SyncCqlSession.java:56) at com.datastax.oss.driver.api.core.cql.SyncCqlSession.execute(SyncCqlSession.java:80) at org.apache.camel.component.cassandra.integration.BaseCassandra.executeCql(BaseCassandra.java:75) at org.apache.camel.component.cassandra.integration.BaseCassandra.executeScript(BaseCassandra.java:69) at org.apache.camel.component.cassandra.integration.BaseCassandra.executeScript(BaseCassandra.java:61) at java.base/java.lang.reflect.Method.invoke(Method.java:580) at java.base/java.util.ArrayList.forEach(ArrayList.java:1596) at java.base/java.util.ArrayList.forEach(ArrayList.java:1596) ``` the test when passing is usually taking between 2 and 4 seconds so maybe a bit too close from the timeout of the request Signed-off-by: Aurélien Pupier --- .../camel/component/cassandra/integration/BaseCassandra.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/BaseCassandra.java b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/BaseCassandra.java index e7e2724431b4f..9ea8bdb61cba7 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/BaseCassandra.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/BaseCassandra.java @@ -96,7 +96,7 @@ public CqlSession getSession() { .withLocalDatacenter(DATACENTER_NAME) .withKeyspace(KEYSPACE_NAME) .withConfigLoader(DriverConfigLoader.programmaticBuilder() - .withDuration(DefaultDriverOption.REQUEST_TIMEOUT, Duration.ofSeconds(5)).build()) + .withDuration(DefaultDriverOption.REQUEST_TIMEOUT, Duration.ofSeconds(10)).build()) .addContactPoint(endpoint).build(); } return session;