Hi, I have tried with `default` id generation strategy Below are the logs that i am getting. It's a null pointer exception but I am sending only hashmap and a long variable inside the RecordNewMessage
2014-11-25 12:37:56 INFO Cluster(akka://ClusterSystem):74 - Cluster Node [akka.tcp://[email protected]:2551] - Metrics will be retreived from MBeans, and may be incorrect on some platforms. To increase metric accuracy add the 'sigar.jar' to the classpath and the appropriate platform-specific native libary to 'java.library.path'. Reason: java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar 2014-11-25 12:37:56 INFO Cluster(akka://ClusterSystem):74 - Cluster Node [akka.tcp://[email protected]:2551] - Metrics collection has started successfully 2014-11-25 12:37:56 INFO LocalActorRef:74 - Message [akka.dispatch.sysmsg.Terminate] from Actor[akka://ClusterSystem/system/cluster/core/daemon/firstSeedNodeProcess-1#-864068775] to Actor[akka://ClusterSystem/system/cluster/core/daemon/firstSeedNodeProcess-1#-864068775] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. 2014-11-25 12:37:56 INFO Cluster(akka://ClusterSystem):74 - Cluster Node [akka.tcp://[email protected]:2551] - Node [akka.tcp://[email protected]:2551] is JOINING, roles [fileconsumernode] 2014-11-25 12:37:57 INFO Cluster(akka://ClusterSystem):74 - Cluster Node [akka.tcp://[email protected]:2551] - Leader is moving node [akka.tcp://[email protected]:2551] to [Up] 2014-11-25 12:38:01 INFO Cluster(akka://ClusterSystem):74 - Cluster Node [akka.tcp://[email protected]:2551] - Node [akka.tcp://[email protected]:2552] is JOINING, roles [filetransformernode] 2014-11-25 12:38:01 INFO Cluster(akka://ClusterSystem):74 - Cluster Node [akka.tcp://[email protected]:2552] - Welcome from [akka.tcp://[email protected]:2551] transformer node Added 2014-11-25 12:38:02 INFO Cluster(akka://ClusterSystem):74 - Cluster Node [akka.tcp://[email protected]:2551] - Leader is moving node [akka.tcp://[email protected]:2552] to [Up] actor selection string is akka.tcp://[email protected]:2552/user/filetransformernode process Message actor selection string is akka.tcp://[email protected]:2552/user/filetransformernode 2014-11-25 12:38:04 ERROR EndpointWriter:65 - AssociationError [akka.tcp://[email protected]:2552] <- [akka.tcp://[email protected]:2551]: Error [java.lang.NullPointerException Serialization trace: header (com.xyz.message.RecordNewMessage)] [ com.esotericsoftware.kryo.KryoException: java.lang.NullPointerException Serialization trace: header (com.xyz.message.RecordNewMessage) at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:125) at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:528) at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:761) at com.romix.akka.serialization.kryo.KryoBasedSerializer.fromBinary(KryoSerializer.scala:394) at com.romix.akka.serialization.kryo.KryoSerializer.fromBinary(KryoSerializer.scala:239) at akka.serialization.Serialization$$anonfun$deserialize$1.apply(Serialization.scala:104) at scala.util.Try$.apply(Try.scala:161) at akka.serialization.Serialization.deserialize(Serialization.scala:98) at akka.remote.serialization.MessageContainerSerializer.fromBinary(MessageContainerSerializer.scala:63) at akka.serialization.Serialization$$anonfun$deserialize$1.apply(Serialization.scala:104) at scala.util.Try$.apply(Try.scala:161) at akka.serialization.Serialization.deserialize(Serialization.scala:98) at akka.remote.MessageSerializer$.deserialize(MessageSerializer.scala:23) at akka.remote.DefaultMessageDispatcher.payload$lzycompute$1(Endpoint.scala:58) at akka.remote.DefaultMessageDispatcher.payload$1(Endpoint.scala:58) at akka.remote.DefaultMessageDispatcher.dispatch(Endpoint.scala:76) at akka.remote.EndpointReader$$anonfun$receive$2.applyOrElse(Endpoint.scala:937) at akka.actor.Actor$class.aroundReceive(Actor.scala:465) at akka.remote.EndpointActor.aroundReceive(Endpoint.scala:415) 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:262) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:975) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1478) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104) Caused by: java.lang.NullPointerException at java.util.HashMap.put(HashMap.java:497) at com.esotericsoftware.kryo.serializers.MapSerializer.read(MapSerializer.java:144) at com.esotericsoftware.kryo.serializers.MapSerializer.read(MapSerializer.java:21) at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:679) at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:106) ... 27 more ] 2014-11-25 12:38:04 ERROR Remoting:66 - java.lang.NullPointerException Serialization trace: header (com.xyz.message.RecordNewMessage) com.esotericsoftware.kryo.KryoException: java.lang.NullPointerException Serialization trace: RecordNewMessage.java class is :- public class RecordNewMessage implements Serializable{ private static final long serialVersionUID = 1L; private final Map<String,String> header; private final long startTime; public RecordNewMessage(Map<String, String> header, long startTime) { this.header = header; this.startTime=startTime; } public Map<String, String> getHeader() { return header; } public long getStartTime() { return startTime; } } Can you please let me know where i am wrong with kryo?? On Saturday, November 22, 2014 3:24:11 PM UTC+5:30, Akka Team wrote: > > Are both nodes configured to use kryo? > What's the error you're getting? > Try `default` id generation strategy, like mentioned in another thread > this week. > > --konrad > > On Thu, Nov 20, 2014 at 7:06 PM, neeraj negi <[email protected] > <javascript:>> wrote: > >> Hi, >> >> I have two node system which was working fine till i have added the kryo. >> >> Attached file is the application.conf that i am using. >> >> KRYO causing the other node unregistered. >> >> do i need to change something in the configuration???? >> >> >> -- >> >>>>>>>>>> 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] <javascript:>. >> To post to this group, send email to [email protected] >> <javascript:>. >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > > > -- > Akka Team > Typesafe - The software stack for applications that scale > Blog: letitcrash.com > Twitter: @akkateam > -- >>>>>>>>>> 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.
