This is an automated email from the ASF dual-hosted git repository. chibenwa pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 20f566aacc659ce7137dffe7482be6595edb05a5 Author: Benoit TELLIER <[email protected]> AuthorDate: Tue Sep 15 08:50:27 2026 +0200 [FIX] Cassandra 5 support dateof(now()) -> toTimestamp(now()) --- .../org/apache/james/backends/cassandra/init/ClusterFactory.java | 2 +- .../apache/james/backends/cassandra/init/ClusterFactoryTest.java | 2 +- .../task/eventsourcing/distributed/DistributedTaskManagerTest.java | 6 +++--- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/ClusterFactory.java b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/ClusterFactory.java index d3d25c1b04..681ea66f82 100644 --- a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/ClusterFactory.java +++ b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/ClusterFactory.java @@ -114,6 +114,6 @@ public class ClusterFactory { } private static void ensureContactable(CqlSession session) { - session.execute("SELECT dateof(now()) FROM system.local ;"); + session.execute("SELECT toTimestamp(now()) FROM system.local;"); } } diff --git a/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/ClusterFactoryTest.java b/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/ClusterFactoryTest.java index 5908eb7a3f..eafc2b2db1 100644 --- a/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/ClusterFactoryTest.java +++ b/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/ClusterFactoryTest.java @@ -66,7 +66,7 @@ class ClusterFactoryTest { void assertThatClusterIsContactable(CqlSession session) { try { - session.execute("SELECT dateof(now()) FROM system.local ;"); + session.execute("SELECT toTimestamp(now()) FROM system.local;"); } catch (Exception e) { throw new AssertionError("expecting cluster can be connected but actually not", e); } diff --git a/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java b/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java index 75feb9b7da..7db3f9dd58 100644 --- a/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java +++ b/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java @@ -667,14 +667,14 @@ class DistributedTaskManagerTest implements TaskManagerContract { this.pause = pause; // Some task requires cassandra query execution upon their creation - Mono.from(session.executeReactive("SELECT dateof(now()) FROM system.local ;")) + Mono.from(session.executeReactive("SELECT toTimestamp(now()) FROM system.local;")) .block(); } @Override public Result run() throws InterruptedException { // Task often execute Cassandra logic - Mono.from(session.executeReactive("SELECT dateof(now()) FROM system.local ;")) + Mono.from(session.executeReactive("SELECT toTimestamp(now()) FROM system.local;")) .block(); if (pause) { @@ -692,7 +692,7 @@ class DistributedTaskManagerTest implements TaskManagerContract { @Override public Mono<Optional<TaskExecutionDetails.AdditionalInformation>> detailsReactive() { // Some task requires cassandra query execution upon detail generation - return Mono.from(session.executeReactive("SELECT dateof(now()) FROM system.local ;")) + return Mono.from(session.executeReactive("SELECT toTimestamp(now()) FROM system.local;")) .thenReturn(Optional.empty()); } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
