This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 7dd5d73071 get avoid snapshot interval calculate int overflow (#1088)
7dd5d73071 is described below
commit 7dd5d73071f17f2fae9ad447493450fd460a8c2d
Author: AndyChen(JingZhangChen) <[email protected]>
AuthorDate: Thu Feb 1 02:29:27 2024 +0800
get avoid snapshot interval calculate int overflow (#1088)
Signed-off-by: Andy.Chen <[email protected]>
---
.../pekko/persistence/typed/internal/RetentionCriteriaImpl.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/RetentionCriteriaImpl.scala
b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/RetentionCriteriaImpl.scala
index 5c125ecabf..6caa28b80d 100644
---
a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/RetentionCriteriaImpl.scala
+++
b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/internal/RetentionCriteriaImpl.scala
@@ -36,14 +36,14 @@ import pekko.persistence.typed.scaladsl
def deleteUpperSequenceNr(lastSequenceNr: Long): Long = {
// Delete old events, retain the latest
- math.max(0, lastSequenceNr - (keepNSnapshots * snapshotEveryNEvents))
+ math.max(0, lastSequenceNr - (keepNSnapshots.toLong *
snapshotEveryNEvents))
}
def deleteLowerSequenceNr(upperSequenceNr: Long): Long = {
// We could use 0 as fromSequenceNr to delete all older snapshots, but
that might be inefficient for
// large ranges depending on how it's implemented in the snapshot plugin.
Therefore we use the
// same window as defined for how much to keep in the retention criteria
- math.max(0, upperSequenceNr - (keepNSnapshots * snapshotEveryNEvents))
+ math.max(0, upperSequenceNr - (keepNSnapshots.toLong *
snapshotEveryNEvents))
}
override def withDeleteEventsOnSnapshot: SnapshotCountRetentionCriteriaImpl =
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
