From 97fdcc157f19b069c395def2ac82ff2a6aefda6c Mon Sep 17 00:00:00 2001 From: "AndyChen(Jingzhang)" Date: Thu, 30 May 2024 14:10:11 +0800 Subject: [PATCH] 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 --- .../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 54e504b2..352721d7 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