java.lang.RuntimeException: 5377 from akka projection with cassandra

Akka
1

Hi,

Can I get some tips on troubleshooting this error?

Jan 28 16:28:20 compute2 nt-ui[822370]: Restarting stream due to failure [1]: java.lang.RuntimeException: 5377 missing tagged events for tag [my-tag]. Failing without search
                                        java.lang.RuntimeException: 5377 missing tagged events for tag [my-tag]. Failing without search
                                                at akka.persistence.cassandra.query.EventsByTagStage$$anon$2.failTooManyMissing(EventsByTagStage.scala:791)
                                                at akka.persistence.cassandra.query.EventsByTagStage$$anon$2.tryPushOne(EventsByTagStage.scala:820)
                                                at akka.persistence.cassandra.query.EventsByTagStage$$anon$2.$anonfun$newResultSetCb$1(EventsByTagStage.scala:285)
                                                at akka.persistence.cassandra.query.EventsByTagStage$$anon$2.$anonfun$newResultSetCb$1$adapted(EventsByTagStage.scala:274)
                                                at akka.stream.impl.fusing.GraphInterpreter.runAsyncInput(GraphInterpreter.scala:467)
                                                at akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:517)
                                                at akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:625)
                                                at akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:800)
                                                at akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:818)
                                                at akka.actor.Actor.aroundReceive(Actor.scala:537)
                                                at akka.actor.Actor.aroundReceive$(Actor.scala:535)
                                                at akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:716)
                                                at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
                                                at akka.actor.ActorCell.invoke(ActorCell.scala:548)
                                                at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
                                                at akka.dispatch.Mailbox.run(Mailbox.scala:231)
                                                at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
                                                at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
                                                at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
                                                at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
                                                at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
                                                at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)