pjfanning opened a new issue, #482:
URL: https://github.com/apache/pekko-projection/issues/482
pekko-projection-grpc is new and never released. We are picking up 3 year
old changes from Akka that have just become Apache licensed.
Big rewrites become available every few weeks.
I'd prefer to come back to this when we pick up the next big set of grpc
changes because there is a good chance that this issue is due to some edge
cases that were later improved on.
```
Error: 5-19 00:54:10,514] [ERROR]
[org.apache.pekko.projection.r2dbc.internal.R2dbcProjectionImpl$R2dbcInternalProjectionState]
[pekko://IntegrationSpec] []
[IntegrationSpec-pekko.actor.default-dispatcher-13] -
[f899b2f5-989c-492b-9d7d-3f81c9d29bcd-00] Failed to process envelope with
offset
[TimestampOffset(2026-05-19T00:54:09.734028Z,1970-01-01T00:00:00Z,Map(TestEntity-4|p-7
-> 2))]. Projection will stop as defined by recovery strategy.
java.lang.IllegalStateException: Event was not loaded. Use eventOption and
load the event on demand with LoadEventQuery.
at
org.apache.pekko.persistence.query.typed.EventEnvelope.event(EventEnvelope.scala:191)
at
org.apache.pekko.projection.grpc.IntegrationSpec$TestHandler.process(IntegrationSpec.scala:88)
at
org.apache.pekko.projection.grpc.IntegrationSpec$TestHandler.process(IntegrationSpec.scala:84)
at
org.apache.pekko.projection.r2dbc.internal.R2dbcProjectionImpl$$anon$4.$anonfun$process$17(R2dbcProjectionImpl.scala:296)
at scala.concurrent.impl.Promise$Transformation.run(Promise.scala:503)
at
org.apache.pekko.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:73)
at
org.apache.pekko.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:110)
at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)
at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:94)
at
org.apache.pekko.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:110)
at
org.apache.pekko.dispatch.TaskInvocation.run(AbstractDispatcher.scala:59)
at
org.apache.pekko.dispatch.ForkJoinExecutorConfigurator$PekkoForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:79)
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
[2026-05-19 00:54:10,518] [WARN]
[org.apache.pekko.stream.scaladsl.RestartWithBackoffSource]
[pekko://IntegrationSpec] []
[IntegrationSpec-pekko.actor.default-dispatcher-12] - Restarting stream due to
failure [1]: java.lang.IllegalStateException: Event was not loaded. Use
eventOption and load the event on demand with LoadEventQuery.
java.lang.IllegalStateException: Event was not loaded. Use eventOption and
load the event on demand with LoadEventQuery.
at
org.apache.pekko.persistence.query.typed.EventEnvelope.event(EventEnvelope.scala:191)
at
org.apache.pekko.projection.grpc.IntegrationSpec$TestHandler.process(IntegrationSpec.scala:88)
at
org.apache.pekko.projection.grpc.IntegrationSpec$TestHandler.process(IntegrationSpec.scala:84)
at
org.apache.pekko.projection.r2dbc.internal.R2dbcProjectionImpl$$anon$4.$anonfun$process$17(R2dbcProjectionImpl.scala:296)
at scala.concurrent.impl.Promise$Transformation.run(Promise.scala:503)
at
org.apache.pekko.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:73)
at
org.apache.pekko.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:110)
at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)
at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:94)
at
org.apache.pekko.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:110)
at
org.apache.pekko.dispatch.TaskInvocation.run(AbstractDispatcher.scala:59)
at
org.apache.pekko.dispatch.ForkJoinExecutorConfigurator$PekkoForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:79)
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
[2026-05-19 00:54:13,512] [INFO]
[org.apache.pekko.actor.testkit.typed.scaladsl.LogCapturing] [] []
[pool-27-thread-7-ScalaTest-running-IntegrationSpec] - Logging finished for
test [org.apache.pekko.projection.grpc.IntegrationSpec: A gRPC Projection must
filter out events] that [Failed(java.lang.AssertionError: Timeout (3 seconds)
during receiveMessage while waiting for message.)]
<-- [org.apache.pekko.projection.grpc.IntegrationSpec: A gRPC Projection
must filter out events] End of log messages of test that
[Failed(java.lang.AssertionError: Timeout (3 seconds) during receiveMessage
while waiting for message.)]
[info] - must filter out events *** FAILED *** (3 seconds, 825 milliseconds)
[info] java.lang.AssertionError: Timeout (3 seconds) during receiveMessage
while waiting for message.
[info] at
org.apache.pekko.actor.testkit.typed.internal.TestProbeImpl.$anonfun$receiveMessage_internal$1(TestProbeImpl.scala:410)
[info] at scala.Option.getOrElse(Option.scala:201)
[info] at
org.apache.pekko.actor.testkit.typed.internal.TestProbeImpl.receiveMessage_internal(TestProbeImpl.scala:193)
[info] at
org.apache.pekko.actor.testkit.typed.internal.TestProbeImpl.receiveMessage(TestProbeImpl.scala:186)
[info] at
org.apache.pekko.projection.grpc.IntegrationSpec$$anon$3.<init>(IntegrationSpec.scala:272)
[info] at
org.apache.pekko.projection.grpc.IntegrationSpec.$anonfun$new$3(IntegrationSpec.scala:255)
[info] at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
[info] at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)
[info] at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
[info] at org.scalatest.Transformer.apply(Transformer.scala:22)
[info] at org.scalatest.Transformer.apply(Transformer.scala:20)
[info] at
org.scalatest.wordspec.AnyWordSpecLike$$anon$3.apply(AnyWordSpecLike.scala:1240)
[info] at
org.apache.pekko.actor.testkit.typed.scaladsl.LogCapturing.withFixture(LogCapturing.scala:80)
[info] at
org.apache.pekko.actor.testkit.typed.scaladsl.LogCapturing.withFixture$(LogCapturing.scala:78)
[info] at
org.apache.pekko.projection.grpc.IntegrationSpec.withFixture(IntegrationSpec.scala:106)
[info] at
org.scalatest.wordspec.AnyWordSpecLike.invokeWithFixture$1(AnyWordSpecLike.scala:1238)
[info] at
org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTest$1(AnyWordSpecLike.scala:1250)
[info] at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
[info] at
org.scalatest.wordspec.AnyWordSpecLike.runTest(AnyWordSpecLike.scala:1250)
[info] at
org.scalatest.wordspec.AnyWordSpecLike.runTest$(AnyWordSpecLike.scala:1232)
[info] at
org.apache.pekko.projection.grpc.IntegrationSpec.runTest(IntegrationSpec.scala:106)
[info] at
org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTests$1(AnyWordSpecLike.scala:1309)
[info] at
org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:413)
[info] at scala.collection.immutable.List.foreach(List.scala:323)
[info] at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
[info] at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:390)
[info] at
org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:427)
[info] at scala.collection.immutable.List.foreach(List.scala:323)
[info] at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
[info] at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:396)
[info] at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:475)
[info] at
org.scalatest.wordspec.AnyWordSpecLike.runTests(AnyWordSpecLike.scala:1309)
[info] at
org.scalatest.wordspec.AnyWordSpecLike.runTests$(AnyWordSpecLike.scala:1308)
[info] at
org.apache.pekko.projection.grpc.IntegrationSpec.runTests(IntegrationSpec.scala:106)
[info] at org.scalatest.Suite.run(Suite.scala:1114)
[info] at org.scalatest.Suite.run$(Suite.scala:1096)
[info] at
org.apache.pekko.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit.org$scalatest$BeforeAndAfterAll$$super$run(ScalaTestWithActorTestKit.scala:42)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
