This is an automated email from the ASF dual-hosted git repository.
apupier pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new f816553002c4 CAMEL-24787 - reduce flakiness of Cassandra Integration
tests
f816553002c4 is described below
commit f816553002c43de7fb279d7a171f8fdc7b94e393
Author: Aurélien Pupier <[email protected]>
AuthorDate: Fri Sep 18 10:38:16 2026 +0200
CAMEL-24787 - reduce flakiness of Cassandra Integration tests
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 <[email protected]>
---
.../org/apache/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 e7e2724431b4..9ea8bdb61cba 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 abstract class BaseCassandra implements
ConfigurableRoute, CamelTestSuppo
.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;