Failed: EventsByPersistenceId

[chbatey]

https://travis-ci.org/akka/akka-persistence-cassandra/jobs/357419611

[info] EventsByPersistenceIdSpec:
Picked up _JAVA_OPTIONS: -Xmx2048m -Xms512m
03/23 14:48:00 ERROR[main] o.a.c.s.StartupChecks - cassandra.jmx.local.port missing from cassandra-env.sh, unable to start local JMX service.
[info] Cassandra query EventsByPersistenceId
[info] - must find existing events (270 milliseconds)
[info] - must find existing events from a sequence number (64 milliseconds)
[info] - must not see any events if the stream starts after current latest event (50 milliseconds)
[info] - must find existing events up to a sequence number (32 milliseconds)
[info] - must not see new events after demand request (236 milliseconds)
[info] - must only deliver what requested if there is more in the buffer (2 seconds, 10 milliseconds)
[info] - must stop if there are no events (18 milliseconds)
[info] - must produce correct sequence of sequence numbers and offsets (30 milliseconds)
[info] - must produce correct sequence of events across multiple partitions (154 milliseconds)
[info] - must (eventually) produce correct sequence of sequence numbers when events appear out of order in cassandra *** FAILED *** (5 seconds, 382 milliseconds)
[info]   java.lang.AssertionError: assertion failed: expected OnNext((jo,3,Sequence(3))), found OnError(java.lang.IllegalStateException: Sequence number [3] still missing after [4.000 s], saw unexpected seqNr [4] for persistenceId [jo].
[info] 	at akka.persistence.cassandra.query.EventsByPersistenceIdStage$$anon$1.lookForMissingSeqNr(EventsByPersistenceIdStage.scala:367)
[info] 	at akka.persistence.cassandra.query.EventsByPersistenceIdStage$$anon$1.onTimer(EventsByPersistenceIdStage.scala:347)
[info] 	at akka.stream.stage.TimerGraphStageLogic.onInternalTimer(GraphStage.scala:1452)
[info] 	at akka.stream.stage.TimerGraphStageLogic.$anonfun$getTimerAsyncCallback$1(GraphStage.scala:1441)
[info] 	at akka.stream.stage.TimerGraphStageLogic.$anonfun$getTimerAsyncCallback$1$adapted(GraphStage.scala:1441)
[info] 	at akka.stream.impl.fusing.GraphInterpreter.runAsyncInput(GraphInterpreter.scala:447)
[info] 	at akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:465)
[info] 	at akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:560)
[info] 	at akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:742)
[info] 	at akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:757)
[info] 	at akka.actor.Actor.aroundReceive(Actor.scala:517)
[info] 	at akka.actor.Actor.aroundReceive$(Actor.scala:515)
[info] 	at akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:667)
[info] 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:527)
[info] 	at akka.actor.ActorCell.invoke(ActorCell.scala:496)
[info] 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
[info] 	at akka.dispatch.Mailbox.run(Mailbox.scala:224)
[info] 	at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
[info] 	at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
[info] 	at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
[info] 	at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
[info] 	at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[info] )