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.s
