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 0ede6986a9354c65ee42f1469d22a7f8a5526930
Author: Benoit TELLIER <[email protected]>
AuthorDate: Sun Aug 16 16:44:26 2026 +0700

    [FIX] Single row to read eventStore snapshots
---
 .../apache/james/eventsourcing/eventstore/cassandra/EventStoreDao.scala  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/event-sourcing/event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/EventStoreDao.scala
 
b/event-sourcing/event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/EventStoreDao.scala
index 63f013d925..75b74e2288 100644
--- 
a/event-sourcing/event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/EventStoreDao.scala
+++ 
b/event-sourcing/event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/EventStoreDao.scala
@@ -73,6 +73,7 @@ class EventStoreDao @Inject() (val session: CqlSession,
       .selectFrom(EVENTS_TABLE)
       .column(SNAPSHOT)
       .whereColumn(AGGREGATE_ID).isEqualTo(bindMarker(AGGREGATE_ID))
+      .limit(1)
       .build())
 
   private def prepareSelectFrom(session: CqlSession): PreparedStatement =


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to