This is an automated email from the ASF dual-hosted git repository.
roiocam pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-persistence-jdbc.git
The following commit(s) were added to refs/heads/main by this push:
new 0d0a85d fix: flaky H2ScalaAllPersistenceIdsTest (#199)
0d0a85d is described below
commit 0d0a85d2fc46a3b7d75a3613db13e7065fae83fb
Author: AndyChen(Jingzhang) <[email protected]>
AuthorDate: Thu May 30 14:10:11 2024 +0800
fix: flaky H2ScalaAllPersistenceIdsTest (#199)
* fix: flaky H2ScalaAllPersistenceIdsTest
* use Shaping ThrottleMode
* rollback to original stream ways...
* slow down the db query
* fix delaySource flaky
* eager fetch
* not need config override
---
.../apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala
index 54e504b..352721d 100644
---
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala
+++
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala
@@ -94,7 +94,7 @@ class JdbcReadJournal(config: Config, configPath:
String)(implicit val system: E
JournalSequenceActor.props(readJournalDao,
readJournalConfig.journalSequenceRetrievalConfiguration),
s"$configPath.pekko-persistence-jdbc-journal-sequence-actor")
private val delaySource =
- Source.tick(0.seconds, readJournalConfig.refreshInterval, 0).take(1)
+ Source.tick(0.seconds, readJournalConfig.refreshInterval, 0)
/**
* Same type of query as `persistenceIds` but the event stream
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
