Hi
i tried rename field schema evolution steps mentioned in lagom documentation but i get deserailaze exception while reading old data for the field which i changed to new field of case class
i tried both imperative migration code and transformer based migration but still get exception can u suggest why migration code is not kicking off while deserialization
I saw Akka documentation that we can add eventAdapter to transform state object can you tell me how we can do that if my entity object is extending to com.lightbend.lagom.scaladsl.persistence.PersistentEntity
akkaTimestamp=03:36:24.379UTC] Persistence failure when replaying events for persistenceId [DocumentEntity|3333334]. Last known sequence number [0]
com.lightbend.lagom.scaladsl.playjson.JsonSerializationFailed: Failed to de-serialize bytes with manifest [com.abc.document.impl.DocumentCommentsSaved]
errors:
/comments(0)/type: JsonValidationError(List(error.path.missing),WrappedArray())
at com.lightbend.lagom.scaladsl.playjson.PlayJsonSerializer.fromBinary(PlayJsonSerializer.scala:158)
at akka.serialization.Serialization.$anonfun$deserializeByteArray$1(Serialization.scala:218)
at akka.serialization.Serialization.withTransportInformation(Serialization.scala:157)
at akka.serialization.Serialization.deserializeByteArray(Serialization.scala:216)
at akka.serialization.Serialization.$anonfun$deserialize$5(Serialization.scala:206)
at scala.util.Try$.apply(Try.scala:213)
at akka.serialization.Serialization.deserialize(Serialization.scala:198)
at akka.persistence.cassandra.journal.CassandraJournal$EventDeserializer.deserializedEvent$1(CassandraJournal.scala:815)
at akka.persistence.cassandra.journal.CassandraJournal$EventDeserializer.deserializeEvent(CassandraJournal.scala:823)
at akka.persistence.cassandra.query.EventsByPersistenceIdStage$Extractors$.akka$persistence$cassandra$query$EventsByPersistenceIdStage$Extractors$$extractPersistentRepr(EventsByPersistenceIdStage.scala:168)
at akka.persistence.cassandra.query.EventsByPersistenceIdStage$Extractors$$anon$2.extract(EventsByPersistenceIdStage.scala:134)
at akka.persistence.cassandra.query.scaladsl.CassandraReadJournal.$anonfun$eventsByPersistenceId$5(CassandraReadJournal.scala:640)
at akka.stream.impl.fusing.MapAsyncUnordered$$anon$31.onPush(Ops.scala:1418)
at akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:541)
at akka.stream.impl.fusing.GraphInterpreter.processEvent(GraphInterpreter.scala:495)
at akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:390)
at akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:625)
at akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:502)
at akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:600)
at akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:775)
at akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$shortCircuitBatch(ActorGraphInterpreter.scala:762)
at akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:791)
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:691)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579)
at akka.actor.ActorCell.invoke(ActorCell.scala:547)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
at akka.dispatch.Mailbox.run(Mailbox.scala:231)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)