This looks like a bug in the eventstore plugin that you are using. Please create an issue in its repository. It looks like it's not supporting SerializerWithStringManifest correctly.
/Patrik lör 24 dec. 2016 kl. 09:00 skrev Hengky Sucanda <[email protected]>: > Hi, > > I am running an application using Akka Persistence library, and i have > always run into this issue > > Additional logs i picked up from when everytime the app is starting > > ``` > at > akka.persistence.eventstore.Helpers$RichConnection$.akka$persistence$eventstore$Helpers$RichConnection$$loop$1(Helpers.scala:52) > at > akka.persistence.eventstore.Helpers$RichConnection$$anonfun$akka$persistence$eventstore$Helpers$RichConnection$$foldLeft$1$1.apply(Helpers.scala:57) > at > akka.persistence.eventstore.Helpers$RichConnection$$anonfun$akka$persistence$eventstore$Helpers$RichConnection$$foldLeft$1$1.apply(Helpers.scala:56) > at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:253) > at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:251) > at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) > at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91) > at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91) > at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91) > at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) > at > akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90) > at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.lang.IllegalArgumentException: Unimplemented > deserialization of message with manifest > [akka.cluster.sharding.ShardCoordinator$Internal$State] in > [akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer] > at > akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer.fromBinary(ClusterShardingMessageSerializer.scala:162) > at > akka.serialization.SerializerWithStringManifest.fromBinary(Serializer.scala:131) > at > akka.serialization.Serialization$$anonfun$deserialize$3.apply(Serialization.scala:193) > at scala.util.Try$.apply(Try.scala:192) > at akka.serialization.Serialization.deserialize(Serialization.scala:193) > at > pl.newicom.eventstore.json.SnapshotJsonSerializer$$anonfun$deserialize$1.applyOrElse(JsonSerializerExtension.scala:118) > at > pl.newicom.eventstore.json.SnapshotJsonSerializer$$anonfun$deserialize$1.applyOrElse(JsonSerializerExtension.scala:112) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > pl.newicom.eventstore.json.ScheduledEventSerializer$$anonfun$deserialize$2.applyOrElse(JsonSerializerExtension.scala:84) > at > pl.newicom.eventstore.json.ScheduledEventSerializer$$anonfun$deserialize$2.applyOrElse(JsonSerializerExtension.scala:84) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.CustomSerializer$$anonfun$deserialize$1.applyOrElse(Formats.scala:393) > at > org.json4s.CustomSerializer$$anonfun$deserialize$1.applyOrElse(Formats.scala:393) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.CustomSerializer$$anonfun$deserialize$1.applyOrElse(Formats.scala:393) > at > org.json4s.CustomSerializer$$anonfun$deserialize$1.applyOrElse(Formats.scala:393) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > ... 31 more > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) > at scala.collection.AbstractMap.applyOrElse(Map.scala:59) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.Extraction$.org$json4s$Extraction$$customOrElse(Extraction.scala:593) > at org.json4s.Extraction$ClassInstanceBuilder.result(Extraction.scala:580) > at org.json4s.Extraction$.extract(Extraction.scala:389) > at > org.json4s.Extraction$ClassInstanceBuilder.org$json4s$Extraction$ClassInstanceBuilder$$mkWithTypeHint(Extraction.scala:575) > at > org.json4s.Extraction$ClassInstanceBuilder$$anonfun$result$8.apply(Extraction.scala:584) > at > org.json4s.Extraction$ClassInstanceBuilder$$anonfun$result$8.apply(Extraction.scala:580) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at org.json4s.Extraction$ClassInstanceBuilder.result(Extraction.scala:580) > at org.json4s.Extraction$.extract(Extraction.scala:389) > at org.json4s.Extraction$.extract(Extraction.scala:39) > at > org.json4s.Extraction$.org$json4s$Extraction$$customOrElse(Extraction.scala:594) > org.json4s.package$MappingException: unknown error > at org.json4s.Extraction$.extract(Extraction.scala:43) > at > org.json4s.ExtractableJsonAstNode.extract(ExtractableJsonAstNode.scala:21) > at org.json4s.native.Serialization$.read(Serialization.scala:71) > at org.json4s.Serialization$class.read(Serialization.scala:30) > at org.json4s.native.Serialization$.read(Serialization.scala:32) > at > pl.newicom.eventstore.json.JsonSerializerExtensionImpl.fromBinary(JsonSerializerExtension.scala:44) > at > pl.newicom.eventstore.EventstoreSerializationSupport$class.deserialize(EventstoreSerializationSupport.scala:98) > at > pl.newicom.eventstore.EventstoreSerializationSupport$class.fromEvent(EventstoreSerializationSupport.scala:61) > at > pl.newicom.eventstore.plugin.EventStoreSerializer.fromEvent(EventStoreSerializer.scala:10) > at > pl.newicom.eventstore.plugin.EventStoreSerializer.fromEvent(EventStoreSerializer.scala:27) > at > akka.persistence.eventstore.EventStoreSerialization.deserialize(EventStoreSerialization.scala:13) > at > akka.persistence.eventstore.snapshot.EventStoreSnapshotStore$$anonfun$loadAsync$1$$anonfun$apply$1.applyOrElse(EventStoreSnapshotStore.scala:35) > at > akka.persistence.eventstore.snapshot.EventStoreSnapshotStore$$anonfun$loadAsync$1$$anonfun$apply$1.applyOrElse(EventStoreSnapshotStore.scala:35) > at > akka.persistence.eventstore.snapshot.EventStoreSnapshotStore$$anonfun$loadAsync$1.akka$persistence$eventstore$snapshot$EventStoreSnapshotStore$$anonfun$$fold$1(EventStoreSnapshotStore.scala:24) > at scala.PartialFunction$Lifted.apply(PartialFunction.scala:223) > at scala.PartialFunction$Lifted.apply(PartialFunction.scala:219) > at > akka.persistence.eventstore.Helpers$RichConnection$.akka$persistence$eventstore$Helpers$RichConnection$$loop$1(Helpers.scala:52) > at > akka.persistence.eventstore.Helpers$RichConnection$$anonfun$akka$persistence$eventstore$Helpers$RichConnection$$foldLeft$1$1.apply(Helpers.scala:57) > at > akka.persistence.eventstore.Helpers$RichConnection$$anonfun$akka$persistence$eventstore$Helpers$RichConnection$$foldLeft$1$1.apply(Helpers.scala:56) > at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:253) > at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:251) > at > akka.serialization.Serialization$$anonfun$deserialize$3.apply(Serialization.scala:193) > at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) > at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91) > at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91) > at > akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91) > at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) > at > akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90) > at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.lang.IllegalArgumentException: Unimplemented > deserialization of message with manifest > [akka.cluster.sharding.ShardCoordinator$Internal$State] in > [akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer] > at > akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer.fromBinary(ClusterShardingMessageSerializer.scala:162) > at > akka.serialization.SerializerWithStringManifest.fromBinary(Serializer.scala:131) > at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) > at scala.util.Try$.apply(Try.scala:192) > at akka.serialization.Serialization.deserialize(Serialization.scala:193) > at > pl.newicom.eventstore.json.SnapshotJsonSerializer$$anonfun$deserialize$1.applyOrElse(JsonSerializerExtension.scala:118) > at > pl.newicom.eventstore.json.SnapshotJsonSerializer$$anonfun$deserialize$1.applyOrElse(JsonSerializerExtension.scala:112) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > pl.newicom.eventstore.json.ScheduledEventSerializer$$anonfun$deserialize$2.applyOrElse(JsonSerializerExtension.scala:84) > at > pl.newicom.eventstore.json.ScheduledEventSerializer$$anonfun$deserialize$2.applyOrElse(JsonSerializerExtension.scala:84) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.CustomSerializer$$anonfun$deserialize$1.applyOrElse(Formats.scala:393) > at > org.json4s.CustomSerializer$$anonfun$deserialize$1.applyOrElse(Formats.scala:393) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.CustomSerializer$$anonfun$deserialize$1.applyOrElse(Formats.scala:393) > at > org.json4s.CustomSerializer$$anonfun$deserialize$1.applyOrElse(Formats.scala:393) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > ... 31 more > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at > org.json4s.ext.EnumSerializer$$anonfun$deserialize$1.applyOrElse(EnumSerializer.scala:34) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at scala.PartialFunction$OrElse.apply(PartialFunction.scala:167) > at > org.json4s.Extraction$.org$json4s$Extraction$$customOrElse(Extraction.scala:593) > at org.json4s.Extraction$ClassInstanceBuilder.result(Extraction.scala:580) > at org.json4s.Extraction$.extract(Extraction.scala:389) > at > org.json4s.Extraction$ClassInstanceBuilder.org$json4s$Extraction$ClassInstanceBuilder$$mkWithTypeHint(Extraction.scala:575) > at > org.json4s.Extraction$ClassInstanceBuilder$$anonfun$result$8.apply(Extraction.scala:584) > at > org.json4s.Extraction$ClassInstanceBuilder$$anonfun$result$8.apply(Extraction.scala:580) > at > org.json4s.Extraction$.org$json4s$Extraction$$customOrElse(Extraction.scala:594) > at org.json4s.Extraction$ClassInstanceBuilder.result(Extraction.scala:580) > at org.json4s.Extraction$.extract(Extraction.scala:389) > at org.json4s.Extraction$.extract(Extraction.scala:39) > at scala.collection.AbstractMap.applyOrElse(Map.scala:59) > ``` > > As far as i understand it, do i need to implement a serializer and > deserializer that can translates > [akka.cluster.sharding.ShardCoordinator$Internal$State] > in [akka.cluster.sharding.protobuf.ClusterShardingMessageSerializer]. > Because it seems like this is a missing serializer inside Akka. > > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to [email protected]. > To post to this group, send email to [email protected]. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
