Hi, You're trying to send something which is not serializable, you'll need to either switch to something that is serializable given the JavaSerializer, or switch to using another serializer.
Or did I misunderstand your question? On Mon, Mar 31, 2014 at 7:26 PM, Santoash Rajaram <[email protected]>wrote: > Im trying to run a cluster with 3 nodes (in dev). I see the following > error in the two non seed nodes: > > [ERROR] [03/31/2014 10:02:25.666] > [Banzai-akka.remote.default-remote-dispatcher-6] > [akka.tcp://MyActorSystem@localhost:2556/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FBanzai%40localhost%3A2552-0/endpointWriter] > Transient association error (association remains live) > > java.io.NotSerializableException: > scala.collection.immutable.MapLike$$anon$1 > > at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1181) > > at > java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1541) > > at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1506) > > at > java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1429) > > at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1175) > > at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:347) > > at > akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply$mcV$sp(Serializer.scala:129) > > at > akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply(Serializer.scala:129) > > at > akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply(Serializer.scala:129) > > at scala.util.DynamicVariable.withValue(DynamicVariable.scala:57) > > at akka.serialization.JavaSerializer.toBinary(Serializer.scala:129) > > at akka.remote.MessageSerializer$.serialize(MessageSerializer.scala:36) > > at > akka.remote.EndpointWriter$$anonfun$akka$remote$EndpointWriter$$serializeMessage$1.apply(Endpoint.scala:713) > > at > akka.remote.EndpointWriter$$anonfun$akka$remote$EndpointWriter$$serializeMessage$1.apply(Endpoint.scala:713) > > at scala.util.DynamicVariable.withValue(DynamicVariable.scala:57) > > at > akka.remote.EndpointWriter.akka$remote$EndpointWriter$$serializeMessage(Endpoint.scala:712) > > at akka.remote.EndpointWriter$$anonfun$7.applyOrElse(Endpoint.scala:594) > > at akka.remote.EndpointWriter$$anonfun$7.applyOrElse(Endpoint.scala:581) > > at > scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:33) > > at akka.actor.FSM$class.processEvent(FSM.scala:604) > > at akka.remote.EndpointWriter.processEvent(Endpoint.scala:479) > > at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:598) > > at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:592) > > at akka.actor.Actor$class.aroundReceive(Actor.scala:465) > > at akka.remote.EndpointActor.aroundReceive(Endpoint.scala:409) > > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) > > at akka.actor.ActorCell.invoke(ActorCell.scala:487) > > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) > > at akka.dispatch.Mailbox.run(Mailbox.scala:220) > > at > akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393) > > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > > at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > > Here is what I have in my application.conf: > > remote { > log-remote-lifecycle-events = off > netty.tcp { > hostname = "127.0.0.1" > port = 2552 > } > } > > cluster { > seed-nodes = [ > "akka.tcp://[email protected]:2552", > "akka.tcp://[email protected]:2554" > ] > auto-down-unreachable-after = 10s > retry-unsuccessful-join-after = 10s > } > > > I don't have any specific Serializers specified in my application.conf. > > Please note that when Im running just one node, everything works fine > (obviously). My brief search lead me to this scala issue: > https://issues.scala-lang.org/browse/SI-7005. Im not sure how thats > related to my issue quite yet. > > Am I missing something here? Any pointers would be greatly appreciated. > > Thanks! > > - Santoash > > > > > > > > > > > -- > >>>>>>>>>> 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 http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Cheers, √ -- >>>>>>>>>> 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 http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
