Akka Distributed Data Sample thowing OversizedPayloadException

87 views

Skip to first unread message

Mainak Ghosh

unread,

May 22, 2017, 6:36:22 PM5/22/17

to Akka User List

Hello,

I am trying to run the akka distributed data sample in Java using Akka 2.5. I am getting the following error:

[JVM-3] [INFO] [05/22/2017 16:31:12.845] [ScalaTest-main] [akka.remote.Remoting] Starting remoting

[JVM-1] [INFO] [05/22/2017 16:31:12.861] [ScalaTest-main] [akka.remote.Remoting] Starting remoting

[JVM-2] [INFO] [05/22/2017 16:31:12.970] [ScalaTest-main] [akka.remote.Remoting] Starting remoting

[JVM-3] [INFO] [05/22/2017 16:31:13.277] [ScalaTest-main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://ServiceRegistrySpec@localhost:56893]

[JVM-1] [INFO] [05/22/2017 16:31:13.277] [ScalaTest-main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://ServiceRegistrySpec@localhost:56894]

[JVM-3] [INFO] [05/22/2017 16:31:13.277] [ScalaTest-main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://ServiceRegistrySpec@localhost:56893]

[JVM-1] [INFO] [05/22/2017 16:31:13.277] [ScalaTest-main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://ServiceRegistrySpec@localhost:56894]

[JVM-3] [INFO] [05/22/2017 16:31:13.292] [ScalaTest-main] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56893] - Starting up...

[JVM-1] [INFO] [05/22/2017 16:31:13.292] [ScalaTest-main] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56894] - Starting up...

[JVM-2] [INFO] [05/22/2017 16:31:13.417] [ScalaTest-main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://ServiceRegistrySpec@localhost:56905]

[JVM-2] [INFO] [05/22/2017 16:31:13.417] [ScalaTest-main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://ServiceRegistrySpec@localhost:56905]

[JVM-2] [INFO] [05/22/2017 16:31:13.433] [ScalaTest-main] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56905] - Starting up...

[JVM-3] [INFO] [05/22/2017 16:31:13.593] [ScalaTest-main] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56893] - Registered cluster JMX MBean [akka:type=Cluster]

[JVM-1] [INFO] [05/22/2017 16:31:13.593] [ScalaTest-main] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56894] - Registered cluster JMX MBean [akka:type=Cluster]

[JVM-2] [INFO] [05/22/2017 16:31:13.624] [ScalaTest-main] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56905] - Registered cluster JMX MBean [akka:type=Cluster]

[JVM-2] [INFO] [05/22/2017 16:31:13.624] [ScalaTest-main] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56905] - Started up successfully

[JVM-3] [INFO] [05/22/2017 16:31:13.593] [ScalaTest-main] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56893] - Started up successfully

[JVM-3] [INFO] [05/22/2017 16:31:13.624] [ServiceRegistrySpec-akka.actor.default-dispatcher-5] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56893] - No seed-nodes configured, manual cluster join required

[JVM-1] [INFO] [05/22/2017 16:31:13.593] [ScalaTest-main] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56894] - Started up successfully

[JVM-2] [INFO] [05/22/2017 16:31:13.656] [ServiceRegistrySpec-akka.actor.default-dispatcher-7] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56905] - No seed-nodes configured, manual cluster join required

[JVM-1] [INFO] [05/22/2017 16:31:13.671] [ServiceRegistrySpec-akka.actor.default-dispatcher-6] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56894] - No seed-nodes configured, manual cluster join required

[JVM-1] [INFO] [05/22/2017 16:31:13.921] [ScalaTest-main] [ServiceRegistrySpecMultiJvmNode1(akka://ServiceRegistrySpec)] Role [node-1] started with address [akka.tcp://ServiceRegistrySpec@localhost:56894]

[JVM-2] [INFO] [05/22/2017 16:31:13.968] [ScalaTest-main] [ServiceRegistrySpecMultiJvmNode2(akka://ServiceRegistrySpec)] Role [node-2] started with address [akka.tcp://ServiceRegistrySpec@localhost:56905]

[JVM-3] [INFO] [05/22/2017 16:31:13.999] [ScalaTest-main] [ServiceRegistrySpecMultiJvmNode3(akka://ServiceRegistrySpec)] Role [node-3] started with address [akka.tcp://ServiceRegistrySpec@localhost:56893]

[JVM-1] Run starting. Expected test count is: 5

[JVM-1] ServiceRegistrySpecMultiJvmNode1:

[JVM-1] Demo of a replicated service registry

[JVM-1] [INFO] [05/22/2017 16:31:14.318] [ServiceRegistrySpec-akka.actor.default-dispatcher-17] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56894] - Node [akka.tcp://ServiceRegistrySpec@localhost:56894] is JOINING, roles []

[JVM-2] Run starting. Expected test count is: 5

[JVM-3] Run starting. Expected test count is: 5

[JVM-2] ServiceRegistrySpecMultiJvmNode2:

[JVM-2] Demo of a replicated service registry

[JVM-1] [INFO] [05/22/2017 16:31:14.333] [ServiceRegistrySpec-akka.actor.default-dispatcher-17] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56894] - Leader is moving node [akka.tcp://ServiceRegistrySpec@localhost:56894] to [Up]

[JVM-3] ServiceRegistrySpecMultiJvmNode3:

[JVM-3] Demo of a replicated service registry

[JVM-1] [INFO] [05/22/2017 16:31:14.787] [ServiceRegistrySpec-akka.actor.default-dispatcher-18] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56894] - Node [akka.tcp://ServiceRegistrySpec@localhost:56905] is JOINING, roles []

[JVM-1] [INFO] [05/22/2017 16:31:14.795] [ServiceRegistrySpec-akka.actor.default-dispatcher-3] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56894] - Node [akka.tcp://ServiceRegistrySpec@localhost:56893] is JOINING, roles []

[JVM-3] [INFO] [05/22/2017 16:31:14.912] [ServiceRegistrySpec-akka.actor.default-dispatcher-2] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56893] - Welcome from [akka.tcp://ServiceRegistrySpec@localhost:56894]

[JVM-2] [INFO] [05/22/2017 16:31:14.912] [ServiceRegistrySpec-akka.actor.default-dispatcher-6] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56905] - Welcome from [akka.tcp://ServiceRegistrySpec@localhost:56894]

[JVM-1] [INFO] [05/22/2017 16:31:15.688] [ServiceRegistrySpec-akka.actor.default-dispatcher-18] [akka.cluster.Cluster(akka://ServiceRegistrySpec)] Cluster Node [akka.tcp://ServiceRegistrySpec@localhost:56894] - Leader is moving node [akka.tcp://ServiceRegistrySpec@localhost:56893] to [Up]

[JVM-2] - must join cluster

[JVM-3] - must join cluster

[JVM-1] - must join cluster

[JVM-1] [WARN] [SECURITY][05/22/2017 16:31:17.758] [ServiceRegistrySpec-akka.actor.default-dispatcher-2] [akka.serialization.Serialization(akka://ServiceRegistrySpec)] Using the default Java serializer for class [sample.distributeddata.ServiceRegistry$ServiceKey] which is not recommended because of performance implications. Use another serializer or disable this warning using the setting 'akka.actor.warn-about-java-serializer-usage'

[JVM-3] [WARN] [SECURITY][05/22/2017 16:31:18.156] [ServiceRegistrySpec-akka.actor.default-dispatcher-7] [akka.serialization.Serialization(akka://ServiceRegistrySpec)] Using the default Java serializer for class [sample.distributeddata.ServiceRegistry$ServiceKey] which is not recommended because of performance implications. Use another serializer or disable this warning using the setting 'akka.actor.warn-about-java-serializer-usage'

[JVM-2] [WARN] [SECURITY][05/22/2017 16:31:18.188] [ServiceRegistrySpec-akka.actor.default-dispatcher-9] [akka.serialization.Serialization(akka://ServiceRegistrySpec)] Using the default Java serializer for class [sample.distributeddata.ServiceRegistry$ServiceKey] which is not recommended because of performance implications. Use another serializer or disable this warning using the setting 'akka.actor.warn-about-java-serializer-usage'

[JVM-3] - must replicate service entry

[JVM-1] - must replicate service entry

[JVM-2] - must replicate service entry

[JVM-2] - must replicate updated service entry, and publish to even bus

[JVM-3] - must replicate updated service entry, and publish to even bus

[JVM-1] - must replicate updated service entry, and publish to even bus

[JVM-2] - must remove terminated service

[JVM-3] - must remove terminated service

[JVM-1] - must remove terminated service

[JVM-1] - must replicate many service entries

[JVM-2] - must replicate many service entries

[JVM-3] - must replicate many service entries

[JVM-1] [WARN] [05/22/2017 16:31:21.588] [ServiceRegistrySpec-akka.actor.default-dispatcher-7] [akka://ServiceRegistrySpec/user/controller/127.0.0.1:56930-server1] received dead letter from Actor[akka://ServiceRegistrySpec/deadLetters]: ClientDisconnected

[JVM-2] [INFO] [05/22/2017 16:31:21.432] [ServiceRegistrySpec-akka.remote.default-remote-dispatcher-11] [akka.tcp://ServiceRegistrySpec@localhost:56905/system/remoting-terminator] Shutting down remote daemon.

[JVM-2] [INFO] [05/22/2017 16:31:21.463] [ServiceRegistrySpec-akka.remote.default-remote-dispatcher-11] [akka.tcp://ServiceRegistrySpec@localhost:56905/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports.

[JVM-3] [INFO] [05/22/2017 16:31:21.463] [ServiceRegistrySpec-akka.remote.default-remote-dispatcher-8] [akka.tcp://ServiceRegistrySpec@localhost:56893/system/remoting-terminator] Shutting down remote daemon.

[JVM-2] [WARN] [05/22/2017 16:31:21.635] [ServiceRegistrySpec-akka.actor.default-dispatcher-6] [akka://ServiceRegistrySpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FServiceRegistrySpec%40localhost%3A56894-0/endpointWriter] received dead letter from Actor[akka://ServiceRegistrySpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FServiceRegistrySpec%40localhost%3A56894-0/endpointWriter#-1829988421]: AckIdleCheckTimer

[JVM-1] [ERROR] [05/22/2017 16:31:21.604] [ServiceRegistrySpec-akka.remote.default-remote-dispatcher-9] [akka.tcp://ServiceRegistrySpec@localhost:56894/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FServiceRegistrySpec%40localhost%3A56905-0/endpointWriter] AssociationError [akka.tcp://ServiceRegistrySpec@localhost:56894] <- [akka.tcp://ServiceRegistrySpec@localhost:56905]: Error [Shut down address: akka.tcp://ServiceRegistrySpec@localhost:56905] [

[JVM-2] [WARN] [05/22/2017 16:31:21.682] [ServiceRegistrySpec-akka.actor.default-dispatcher-7] [akka://ServiceRegistrySpec/deadLetters] received dead letter from Actor[akka://ServiceRegistrySpec/system/cluster/core/daemon#1483910487]: GossipStatus(UniqueAddress(akka.tcp://ServiceRegistrySpec@localhost:56905,-1982915504),VectorClock(a0b04861e5edd390b0bcafe3f5bf4237 -> 5))

[JVM-3] [INFO] [05/22/2017 16:31:21.479] [ServiceRegistrySpec-akka.remote.default-remote-dispatcher-8] [akka.tcp://ServiceRegistrySpec@localhost:56893/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports.

[JVM-2] [WARN] [05/22/2017 16:31:21.713] [ServiceRegistrySpec-akka.actor.default-dispatcher-7] [akka://ServiceRegistrySpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FServiceRegistrySpec%40localhost%3A56893-1/endpointWriter/endpointReader-akka.tcp%3A%2F%2FServiceRegistrySpec%40localhost%3A56893-0] received dead letter from Actor[akka://ServiceRegistrySpec/deadLetters]: InboundPayload(size = 259 bytes)

[JVM-1] akka.remote.ShutDownAssociation: Shut down address: akka.tcp://ServiceRegistrySpec@localhost:56905

[JVM-3] [WARN] [05/22/2017 16:31:21.682] [ServiceRegistrySpec-akka.actor.default-dispatcher-4] [akka://ServiceRegistrySpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FServiceRegistrySpec%40localhost%3A56905-1/endpointWriter/endpointReader-akka.tcp%3A%2F%2FServiceRegistrySpec%40localhost%3A56905-0] received dead letter from Actor[akka://ServiceRegistrySpec/deadLetters]: InboundPayload(size = 186 bytes)

[JVM-1] Caused by: akka.remote.transport.Transport$InvalidAssociationException: The remote system terminated the association because it is shutting down.

[JVM-1] ]

[JVM-1] [INFO] [05/22/2017 16:31:21.620] [ServiceRegistrySpec-akka.remote.default-remote-dispatcher-8] [akka.tcp://ServiceRegistrySpec@localhost:56894/system/remoting-terminator] Shutting down remote daemon.

[JVM-1] [WARN] [05/22/2017 16:31:21.698] [ServiceRegistrySpec-akka.actor.default-dispatcher-2] [akka://ServiceRegistrySpec/deadLetters] received dead letter from Actor[akka://ServiceRegistrySpec/system/cluster/core/daemon#1018616669]: GossipStatus(UniqueAddress(akka.tcp://ServiceRegistrySpec@localhost:56894,1159790324),VectorClock(a0b04861e5edd390b0bcafe3f5bf4237 -> 5))

[JVM-1] [WARN] [05/22/2017 16:31:21.713] [ServiceRegistrySpec-akka.actor.default-dispatcher-2] [akka://ServiceRegistrySpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FServiceRegistrySpec%40localhost%3A56893-1/endpointWriter/endpointReader-akka.tcp%3A%2F%2FServiceRegistrySpec%40localhost%3A56893-0] received dead letter from Actor[akka://ServiceRegistrySpec/deadLetters]: InboundPayload(size = 259 bytes)

[JVM-2] Run completed in 11 seconds, 139 milliseconds.

[JVM-1] Run completed in 11 seconds, 54 milliseconds.

[JVM-2] Total number of tests run: 5

[JVM-2] Suites: completed 1, aborted 0

[JVM-2] Tests: succeeded 5, failed 0, canceled 0, ignored 0, pending 0

[JVM-2] All tests passed.

I tried to follow this https://stackoverflow.com/questions/36685326/max-allowed-size-128000-bytes-actual-size-of-encoded-class-scala-error-in-akk. It does not solve the problem. Is this a recent problem?

Thanks,

Mainak.

Patrik Nordwall

unread,

May 23, 2017, 4:15:18 AM5/23/17

to akka...@googlegroups.com

I can't see that error in the log messages you included, but in general: http://doc.akka.io/docs/akka/2.5/scala/distributed-data.html#Limitations

You can sometimes split one data entry into several, e.g. instead of having one huge ORSet you can use 10 ORSet at the top level and pick the right one with hashing.

/Patrik

--
>>>>>>>>>> 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 akka-user+unsubscribe@googlegroups.com.
To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Patrik Nordwall
Akka Tech Lead
Lightbend - Reactive apps on the JVM
Twitter: @patriknw

Mainak Ghosh

unread,

May 23, 2017, 1:25:09 PM5/23/17

to Akka User List

Hey Patrick,

I might have pasted the wrong log. Here is the correct one:

[JVM-1] [INFO] [05/22/2017 16:31:25.245] [ScalaTest-main] [akka.remote.Remoting] Starting remoting

[JVM-3] [INFO] [05/22/2017 16:31:25.245] [ScalaTest-main] [akka.remote.Remoting] Starting remoting

[JVM-2] [INFO] [05/22/2017 16:31:25.355] [ScalaTest-main] [akka.remote.Remoting] Starting remoting

[JVM-3] [INFO] [05/22/2017 16:31:25.665] [ScalaTest-main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://VotingServiceSpec@localhost:56966]

[JVM-3] [INFO] [05/22/2017 16:31:25.681] [ScalaTest-main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://VotingServiceSpec@localhost:56966]

[JVM-3] [INFO] [05/22/2017 16:31:25.696] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56966] - Starting up...

[JVM-1] [INFO] [05/22/2017 16:31:25.728] [ScalaTest-main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://VotingServiceSpec@localhost:56969]

[JVM-1] [INFO] [05/22/2017 16:31:25.728] [ScalaTest-main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://VotingServiceSpec@localhost:56969]

[JVM-1] [INFO] [05/22/2017 16:31:25.747] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56969] - Starting up...

[JVM-3] [INFO] [05/22/2017 16:31:25.830] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56966] - Registered cluster JMX MBean [akka:type=Cluster]

[JVM-3] [INFO] [05/22/2017 16:31:25.830] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56966] - Started up successfully

[JVM-2] [INFO] [05/22/2017 16:31:25.861] [ScalaTest-main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://VotingServiceSpec@localhost:56978]

[JVM-2] [INFO] [05/22/2017 16:31:25.861] [ScalaTest-main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://VotingServiceSpec@localhost:56978]

[JVM-3] [INFO] [05/22/2017 16:31:25.861] [VotingServiceSpec-akka.actor.default-dispatcher-5] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56966] - No seed-nodes configured, manual cluster join required

[JVM-2] [INFO] [05/22/2017 16:31:25.892] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56978] - Starting up...

[JVM-1] [INFO] [05/22/2017 16:31:25.906] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56969] - Registered cluster JMX MBean [akka:type=Cluster]

[JVM-1] [INFO] [05/22/2017 16:31:25.906] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56969] - Started up successfully

[JVM-1] [INFO] [05/22/2017 16:31:25.921] [VotingServiceSpec-akka.actor.default-dispatcher-8] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56969] - No seed-nodes configured, manual cluster join required

[JVM-2] [INFO] [05/22/2017 16:31:26.073] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56978] - Registered cluster JMX MBean [akka:type=Cluster]

[JVM-2] [INFO] [05/22/2017 16:31:26.073] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56978] - Started up successfully

[JVM-2] [INFO] [05/22/2017 16:31:26.104] [VotingServiceSpec-akka.actor.default-dispatcher-3] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56978] - No seed-nodes configured, manual cluster join required

[JVM-1] [INFO] [05/22/2017 16:31:26.260] [ScalaTest-main] [VotingServiceSpecMultiJvmNode1(akka://VotingServiceSpec)] Role [node-1] started with address [akka.tcp://VotingServiceSpec@localhost:56969]

[JVM-2] [INFO] [05/22/2017 16:31:26.338] [ScalaTest-main] [VotingServiceSpecMultiJvmNode2(akka://VotingServiceSpec)] Role [node-2] started with address [akka.tcp://VotingServiceSpec@localhost:56978]

[JVM-3] [INFO] [05/22/2017 16:31:26.338] [ScalaTest-main] [VotingServiceSpecMultiJvmNode3(akka://VotingServiceSpec)] Role [node-3] started with address [akka.tcp://VotingServiceSpec@localhost:56966]

[JVM-1] Run starting. Expected test count is: 2

[JVM-3] Run starting. Expected test count is: 2

[JVM-2] Run starting. Expected test count is: 2

[JVM-3] VotingServiceSpecMultiJvmNode3:

[JVM-1] VotingServiceSpecMultiJvmNode1:

[JVM-3] Demo of a replicated voting

[JVM-2] VotingServiceSpecMultiJvmNode2:

[JVM-1] Demo of a replicated voting

[JVM-2] Demo of a replicated voting

[JVM-1] [INFO] [05/22/2017 16:31:26.566] [VotingServiceSpec-akka.actor.default-dispatcher-3] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56969] - Node [akka.tcp://VotingServiceSpec@localhost:56969] is JOINING, roles []

[JVM-1] [INFO] [05/22/2017 16:31:26.581] [VotingServiceSpec-akka.actor.default-dispatcher-3] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56969] - Leader is moving node [akka.tcp://VotingServiceSpec@localhost:56969] to [Up]

[JVM-1] [INFO] [05/22/2017 16:31:27.128] [VotingServiceSpec-akka.actor.default-dispatcher-8] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56969] - Node [akka.tcp://VotingServiceSpec@localhost:56966] is JOINING, roles []

[JVM-2] [INFO] [05/22/2017 16:31:27.237] [VotingServiceSpec-akka.actor.default-dispatcher-3] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56978] - Welcome from [akka.tcp://VotingServiceSpec@localhost:56969]

[JVM-3] [INFO] [05/22/2017 16:31:27.284] [VotingServiceSpec-akka.actor.default-dispatcher-3] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56966] - Welcome from [akka.tcp://VotingServiceSpec@localhost:56969]

[JVM-1] [INFO] [05/22/2017 16:31:27.928] [VotingServiceSpec-akka.actor.default-dispatcher-4] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:56969] - Leader is moving node [akka.tcp://VotingServiceSpec@localhost:56966] to [Up]

[JVM-2] - must join cluster

[JVM-3] - must join cluster

[JVM-1] - must join cluster

[JVM-1] [ERROR] [05/22/2017 16:31:29.638] [VotingServiceSpec-akka.remote.default-remote-dispatcher-11] [akka.tcp://VotingServiceSpec@localhost:56969/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56966-1/endpointWriter] Transient association error (association remains live)

[JVM-1] akka.remote.OversizedPayloadException: Discarding oversized payload sent to Actor[akka.tcp://VotingServiceSpec@localhost:56966/]: max allowed size 128000 bytes, actual size of encoded class akka.actor.ActorSelectionMessage was 139144 bytes.

[JVM-1]

[JVM-1] [ERROR] [05/22/2017 16:31:29.607] [VotingServiceSpec-akka.remote.default-remote-dispatcher-10] [akka.tcp://VotingServiceSpec@localhost:56969/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56978-0/endpointWriter] Transient association error (association remains live)

[JVM-1] akka.remote.OversizedPayloadException: Discarding oversized payload sent to Actor[akka.tcp://VotingServiceSpec@localhost:56978/]: max allowed size 128000 bytes, actual size of encoded class akka.actor.ActorSelectionMessage was 139144 bytes.

[JVM-1]

[JVM-3] [WARN] [05/22/2017 16:31:31.478] [VotingServiceSpec-akka.actor.default-dispatcher-5] [akka://VotingServiceSpec/user/votingService] unhandled message from Actor[akka://VotingServiceSpec/system/ddataReplicator#-557424321]: Changed(contestClosed)

[JVM-3] [ERROR] [05/22/2017 16:31:31.841] [VotingServiceSpec-akka.remote.default-remote-dispatcher-8] [akka.tcp://VotingServiceSpec@localhost:56966/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56978-1/endpointWriter] Transient association error (association remains live)

[JVM-1] - must count votes correctly

[JVM-2] [ERROR] [05/22/2017 16:31:31.888] [VotingServiceSpec-akka.remote.default-remote-dispatcher-15] [akka.tcp://VotingServiceSpec@localhost:56978/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56966-1/endpointWriter] Transient association error (association remains live)

[JVM-2] akka.remote.OversizedPayloadException: Discarding oversized payload sent to Actor[akka.tcp://VotingServiceSpec@localhost:56966/]: max allowed size 128000 bytes, actual size of encoded class akka.actor.ActorSelectionMessage was 173178 bytes.

[JVM-2]

[JVM-1] [ERROR] [05/22/2017 16:31:32.036] [VotingServiceSpec-akka.remote.default-remote-dispatcher-11] [akka.tcp://VotingServiceSpec@localhost:56969/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56966-1/endpointWriter] AssociationError [akka.tcp://VotingServiceSpec@localhost:56969] <- [akka.tcp://VotingServiceSpec@localhost:56966]: Error [Shut down address: akka.tcp://VotingServiceSpec@localhost:56966] [

[JVM-3] akka.remote.OversizedPayloadException: Discarding oversized payload sent to Actor[akka.tcp://VotingServiceSpec@localhost:56978/]: max allowed size 128000 bytes, actual size of encoded class akka.actor.ActorSelectionMessage was 173178 bytes.

[JVM-1] akka.remote.ShutDownAssociation: Shut down address: akka.tcp://VotingServiceSpec@localhost:56966

[JVM-1] Caused by: akka.remote.transport.Transport$InvalidAssociationException: The remote system terminated the association because it is shutting down.

[JVM-2] [ERROR] [05/22/2017 16:31:31.904] [VotingServiceSpec-akka.remote.default-remote-dispatcher-7] [akka.tcp://VotingServiceSpec@localhost:56978/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56969-0/endpointWriter] Transient association error (association remains live)

[JVM-2] akka.remote.OversizedPayloadException: Discarding oversized payload sent to Actor[akka.tcp://VotingServiceSpec@localhost:56969/]: max allowed size 128000 bytes, actual size of encoded class akka.actor.ActorSelectionMessage was 173178 bytes.

[JVM-2]

[JVM-2] - must count votes correctly

[JVM-2] [INFO] [05/22/2017 16:31:32.005] [VotingServiceSpec-akka.remote.default-remote-dispatcher-15] [akka.tcp://VotingServiceSpec@localhost:56978/system/remoting-terminator] Shutting down remote daemon.

[JVM-2] [ERROR] [05/22/2017 16:31:32.087] [VotingServiceSpec-akka.remote.default-remote-dispatcher-15] [akka.tcp://VotingServiceSpec@localhost:56978/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56966-1/endpointWriter] AssociationError [akka.tcp://VotingServiceSpec@localhost:56978] <- [akka.tcp://VotingServiceSpec@localhost:56966]: Error [Shut down address: akka.tcp://VotingServiceSpec@localhost:56966] [

[JVM-2] akka.remote.ShutDownAssociation: Shut down address: akka.tcp://VotingServiceSpec@localhost:56966

[JVM-2] Caused by: akka.remote.transport.Transport$InvalidAssociationException: The remote system terminated the association because it is shutting down.

[JVM-2] ]

[JVM-2] [WARN] [05/22/2017 16:31:32.137] [VotingServiceSpec-akka.actor.default-dispatcher-6] [akka://VotingServiceSpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56966-1] received dead letter from Actor[akka://VotingServiceSpec/deadLetters]: FlushAndStop

[JVM-2] [WARN] [05/22/2017 16:31:32.168] [VotingServiceSpec-akka.actor.default-dispatcher-6] [akka://VotingServiceSpec/deadLetters] received dead letter from Actor[akka://VotingServiceSpec/system/cluster/core/daemon#-1441987098]: GossipStatus(UniqueAddress(akka.tcp://VotingServiceSpec@localhost:56978,-1577704320),VectorClock(13a8247ce248f470e3052389725b5699 -> 5))

[JVM-2] [INFO] [05/22/2017 16:31:32.168] [VotingServiceSpec-akka.actor.default-dispatcher-6] [akka.remote.Remoting] Remoting shut down

[JVM-2] [INFO] [05/22/2017 16:31:32.168] [VotingServiceSpec-akka.remote.default-remote-dispatcher-7] [akka.tcp://VotingServiceSpec@localhost:56978/system/remoting-terminator] Remoting shut down.

[JVM-1] ]

[JVM-1] [WARN] [05/22/2017 16:31:32.052] [VotingServiceSpec-akka.actor.default-dispatcher-6] [akka://VotingServiceSpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56966-1/endpointWriter] received dead letter from Actor[akka://VotingServiceSpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56966-1/endpointWriter#800255842]: AckIdleCheckTimer

[JVM-1] [INFO] [05/22/2017 16:31:32.052] [VotingServiceSpec-akka.actor.default-dispatcher-3] [akka://VotingServiceSpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56966-1/endpointWriter] Message [akka.remote.EndpointWriter$AckIdleCheckTimer$] from Actor[akka://VotingServiceSpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56966-1/endpointWriter#800255842] to Actor[akka://VotingServiceSpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56966-1/endpointWriter#800255842] 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'.

[JVM-1] [WARN] [05/22/2017 16:31:32.090] [VotingServiceSpec-akka.actor.default-dispatcher-4] [akka://VotingServiceSpec/user/controller/127.0.0.1:56998-server2] received dead letter from Actor[akka://VotingServiceSpec/deadLetters]: ClientDisconnected

[JVM-1] [ERROR] [05/22/2017 16:31:32.100] [VotingServiceSpec-akka.remote.default-remote-dispatcher-10] [akka.tcp://VotingServiceSpec@localhost:56969/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56978-0/endpointWriter] AssociationError [akka.tcp://VotingServiceSpec@localhost:56969] <- [akka.tcp://VotingServiceSpec@localhost:56978]: Error [Shut down address: akka.tcp://VotingServiceSpec@localhost:56978] [

[JVM-1] akka.remote.ShutDownAssociation: Shut down address: akka.tcp://VotingServiceSpec@localhost:56978

[JVM-1] Caused by: akka.remote.transport.Transport$InvalidAssociationException: The remote system terminated the association because it is shutting down.

[JVM-1] ]

[JVM-1] [INFO] [05/22/2017 16:31:32.103] [VotingServiceSpec-akka.remote.default-remote-dispatcher-11] [akka.tcp://VotingServiceSpec@localhost:56969/system/remoting-terminator] Shutting down remote daemon.

[JVM-1] [INFO] [05/22/2017 16:31:32.106] [VotingServiceSpec-akka.remote.default-remote-dispatcher-11] [akka.tcp://VotingServiceSpec@localhost:56969/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports.

[JVM-1] [INFO] [05/22/2017 16:31:32.152] [VotingServiceSpec-akka.actor.default-dispatcher-2] [akka.remote.Remoting] Remoting shut down

[JVM-1] [INFO] [05/22/2017 16:31:32.152] [VotingServiceSpec-akka.remote.default-remote-dispatcher-11] [akka.tcp://VotingServiceSpec@localhost:56969/system/remoting-terminator] Remoting shut down.

[JVM-1] Run completed in 9 seconds, 35 milliseconds.

[JVM-1] Total number of tests run: 2

[JVM-1] Suites: completed 1, aborted 0

[JVM-1] Tests: succeeded 2, failed 0, canceled 0, ignored 0, pending 0

[JVM-1] All tests passed.

[JVM-3]

[JVM-3] [ERROR] [05/22/2017 16:31:31.857] [VotingServiceSpec-akka.remote.default-remote-dispatcher-9] [akka.tcp://VotingServiceSpec@localhost:56966/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A56969-0/endpointWriter] Transient association error (association remains live)

[JVM-2] Run completed in 8 seconds, 848 milliseconds.

[JVM-2] Total number of tests run: 2

[JVM-2] Suites: completed 1, aborted 0

[JVM-3] akka.remote.OversizedPayloadException: Discarding oversized payload sent to Actor[akka.tcp://VotingServiceSpec@localhost:56969/]: max allowed size 128000 bytes, actual size of encoded class akka.actor.ActorSelectionMessage was 173178 bytes.

[JVM-2] Tests: succeeded 2, failed 0, canceled 0, ignored 0, pending 0

[JVM-3]

[JVM-2] All tests passed.

[JVM-3] - must count votes correctly

[JVM-3] [INFO] [05/22/2017 16:31:31.974] [VotingServiceSpec-akka.remote.default-remote-dispatcher-8] [akka.tcp://VotingServiceSpec@localhost:56966/system/remoting-terminator] Shutting down remote daemon.

[JVM-3] [INFO] [05/22/2017 16:31:31.989] [VotingServiceSpec-akka.remote.default-remote-dispatcher-8] [akka.tcp://VotingServiceSpec@localhost:56966/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports.

[JVM-3] [INFO] [05/22/2017 16:31:32.106] [VotingServiceSpec-akka.actor.default-dispatcher-18] [akka.remote.Remoting] Remoting shut down

[JVM-3] [INFO] [05/22/2017 16:31:32.106] [VotingServiceSpec-akka.remote.default-remote-dispatcher-9] [akka.tcp://VotingServiceSpec@localhost:56966/system/remoting-terminator] Remoting shut down.

[JVM-3] Run completed in 8 seconds, 782 milliseconds.

[JVM-3] Total number of tests run: 2

[JVM-3] Suites: completed 1, aborted 0

[JVM-3] Tests: succeeded 2, failed 0, canceled 0, ignored 0, pending 0

[JVM-3] All tests passed.

Are the sample examples broken in the new version of Akka?

Mainak

To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+...@googlegroups.com.

To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Patrik Nordwall

unread,

May 24, 2017, 9:24:52 AM5/24/17

to akka...@googlegroups.com

That's interesting. I see the same problem when running that example. It shouldn't be much data involved there. I have created issue https://github.com/akka/akka-samples/issues/25 and will look into it.

/Patrik

To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscribe@googlegroups.com.

To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Mainak Ghosh

unread,

May 25, 2017, 11:35:26 AM5/25/17

to akka...@googlegroups.com

Hello Patrik,

Will this bug be fixed? Can you suggest me some quick work around?

Thanks,

Mainak

You received this message because you are subscribed to a topic in the Google Groups "Akka User List" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/akka-user/2OnoPDUa6VU/unsubscribe.
To unsubscribe from this group and all its topics, send an email to akka-user+unsubscribe@googlegroups.com.

To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Mainak Ghosh

Patrik Nordwall

unread,

May 25, 2017, 12:08:32 PM5/25/17

to akka...@googlegroups.com

Yes, it will be fixed. I don't think it will cause any critical problems. It's only when you do updates at a high rate and then the delta messages will be dropped. Delivery of deltas are not mandatory for correct end result. Make sure you use latest version, though. 2.5.2.

If it's annoying you can disable deltas until it's fixed.

That said, I think it's an important issue to fix soon. Thanks for reporting.

/Patrik

You received this message because you are subscribed to a topic in the Google Groups "Akka User List" group.

To unsubscribe from this topic, visit https://groups.google.com/d/topic/akka-user/2OnoPDUa6VU/unsubscribe.

To unsubscribe from this group and all its topics, send an email to akka-user+...@googlegroups.com.

To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

--
Mainak Ghosh

Mainak Ghosh

unread,

May 25, 2017, 2:31:26 PM5/25/17

to akka...@googlegroups.com

Hello Patrik,

Let me see if I got this right. I added the following configuration in VotingServiceSpec.scala.

object VotingServiceSpec extends MultiNodeConfig {
  val node1 = role("node-1")
  val node2 = role("node-2")
  val node3 = role("node-3")

  commonConfig(ConfigFactory.parseString("""
    akka.loglevel = INFO
    akka.actor.provider = "cluster"
    akka.log-dead-letters-during-shutdown = off
    akka.cluster.distributed-data.delta-crdt.enabled=off
    """))

}

The execution still throws this error

[trace] Stack trace suppressed: run last compile:compileIncremental for the full output.

[error] (compile:compileIncremental) Could not create directory D:\Github\actor-scaling\MWMRAkka\akka-sample-distributed-data-java\target\scala-2.12\classes.bak

[error] Total time: 1 s, completed May 25, 2017 1:26:12 PM

> multi-jvm:test-only sample.distributeddata.VotingServiceSpec

[info] Compiling 1 Scala source to D:\Github\actor-scaling\MWMRAkka\akka-sample-distributed-data-java\target\scala-2.12\multi-jvm-classes...

[info] * sample.distributeddata.VotingServiceSpec

[JVM-3] [INFO] [05/25/2017 13:26:42.853] [ScalaTest-main] [akka.remote.Remoting] Starting remoting

[JVM-1] [INFO] [05/25/2017 13:26:42.900] [ScalaTest-main] [akka.remote.Remoting] Starting remoting

[JVM-2] [INFO] [05/25/2017 13:26:42.978] [ScalaTest-main] [akka.remote.Remoting] Starting remoting

[JVM-3] [INFO] [05/25/2017 13:26:43.385] [ScalaTest-main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://VotingServiceSpec@localhost:60460]

[JVM-2] [INFO] [05/25/2017 13:26:43.400] [ScalaTest-main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://VotingServiceSpec@localhost:60462]

[JVM-1] [INFO] [05/25/2017 13:26:43.400] [ScalaTest-main] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp://VotingServiceSpec@localhost:60461]

[JVM-1] [INFO] [05/25/2017 13:26:43.400] [ScalaTest-main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://VotingServiceSpec@localhost:60461]

[JVM-1] [INFO] [05/25/2017 13:26:43.416] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60461] - Starting up...

[JVM-2] [INFO] [05/25/2017 13:26:43.400] [ScalaTest-main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://VotingServiceSpec@localhost:60462]

[JVM-2] [INFO] [05/25/2017 13:26:43.416] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60462] - Starting up...

[JVM-3] [INFO] [05/25/2017 13:26:43.385] [ScalaTest-main] [akka.remote.Remoting] Remoting now listens on addresses: [akka.tcp://VotingServiceSpec@localhost:60460]

[JVM-3] [INFO] [05/25/2017 13:26:43.432] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60460] - Starting up...

[JVM-1] [INFO] [05/25/2017 13:26:43.619] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60461] - Registered cluster JMX MBean [akka:type=Cluster]

[JVM-2] [INFO] [05/25/2017 13:26:43.635] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60462] - Registered cluster JMX MBean [akka:type=Cluster]

[JVM-3] [INFO] [05/25/2017 13:26:43.619] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60460] - Registered cluster JMX MBean [akka:type=Cluster]

[JVM-3] [INFO] [05/25/2017 13:26:43.619] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60460] - Started up successfully

[JVM-3] [INFO] [05/25/2017 13:26:43.650] [VotingServiceSpec-akka.actor.default-dispatcher-5] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60460] - No seed-nodes configured, manual cluster join required

[JVM-2] [INFO] [05/25/2017 13:26:43.635] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60462] - Started up successfully

[JVM-2] [INFO] [05/25/2017 13:26:43.666] [VotingServiceSpec-akka.actor.default-dispatcher-4] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60462] - No seed-nodes configured, manual cluster join required

[JVM-1] [INFO] [05/25/2017 13:26:43.619] [ScalaTest-main] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60461] - Started up successfully

[JVM-1] [INFO] [05/25/2017 13:26:43.635] [VotingServiceSpec-akka.actor.default-dispatcher-7] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60461] - No seed-nodes configured, manual cluster join required

[JVM-1] [INFO] [05/25/2017 13:26:43.963] [ScalaTest-main] [VotingServiceSpecMultiJvmNode1(akka://VotingServiceSpec)] Role [node-1] started with address [akka.tcp://VotingServiceSpec@localhost:60461]

[JVM-3] [INFO] [05/25/2017 13:26:44.026] [ScalaTest-main] [VotingServiceSpecMultiJvmNode3(akka://VotingServiceSpec)] Role [node-3] started with address [akka.tcp://VotingServiceSpec@localhost:60460]

[JVM-2] [INFO] [05/25/2017 13:26:44.041] [ScalaTest-main] [VotingServiceSpecMultiJvmNode2(akka://VotingServiceSpec)] Role [node-2] started with address [akka.tcp://VotingServiceSpec@localhost:60462]

[JVM-1] Run starting. Expected test count is: 2

[JVM-1] VotingServiceSpecMultiJvmNode1:

[JVM-2] Run starting. Expected test count is: 2

[JVM-3] Run starting. Expected test count is: 2

[JVM-2] VotingServiceSpecMultiJvmNode2:

[JVM-1] Demo of a replicated voting

[JVM-2] Demo of a replicated voting

[JVM-3] VotingServiceSpecMultiJvmNode3:

[JVM-1] [INFO] [05/25/2017 13:26:44.338] [VotingServiceSpec-akka.actor.default-dispatcher-6] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60461] - Node [akka.tcp://VotingServiceSpec@localhost:60461] is JOINING, roles []

[JVM-3] Demo of a replicated voting

[JVM-1] [INFO] [05/25/2017 13:26:44.369] [VotingServiceSpec-akka.actor.default-dispatcher-6] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60461] - Leader is moving node [akka.tcp://VotingServiceSpec@localhost:60461] to [Up]

[JVM-1] [INFO] [05/25/2017 13:26:44.819] [VotingServiceSpec-akka.actor.default-dispatcher-6] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60461] - Node [akka.tcp://VotingServiceSpec@localhost:60460] is JOINING, roles []

[JVM-3] [INFO] [05/25/2017 13:26:44.913] [VotingServiceSpec-akka.actor.default-dispatcher-16] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60460] - Welcome from [akka.tcp://VotingServiceSpec@localhost:60461]

[JVM-2] [INFO] [05/25/2017 13:26:44.929] [VotingServiceSpec-akka.actor.default-dispatcher-18] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60462] - Welcome from [akka.tcp://VotingServiceSpec@localhost:60461]

[JVM-1] [INFO] [05/25/2017 13:26:45.647] [VotingServiceSpec-akka.actor.default-dispatcher-8] [akka.cluster.Cluster(akka://VotingServiceSpec)] Cluster Node [akka.tcp://VotingServiceSpec@localhost:60461] - Leader is moving node [akka.tcp://VotingServiceSpec@localhost:60460] to [Up]

[JVM-3] - must join cluster

[JVM-2] - must join cluster

[JVM-1] - must join cluster

[JVM-3] [WARN] [05/25/2017 13:26:47.605] [VotingServiceSpec-akka.actor.default-dispatcher-18] [akka://VotingServiceSpec/user/votingService] unhandled message from Actor[akka://VotingServiceSpec/system/ddataReplicator#-745101497]: Changed(contestClosed)

[JVM-1] - must count votes correctly

[JVM-3] - must count votes correctly

[JVM-2] - must count votes correctly

[JVM-2] [ERROR] [05/25/2017 13:26:48.308] [VotingServiceSpec-akka.remote.default-remote-dispatcher-8] [akka.tcp://VotingServiceSpec@localhost:60462/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A60460-1/endpointWriter] AssociationError [akka.tcp://VotingServiceSpec@localhost:60462] -> [akka.tcp://VotingServiceSpec@localhost:60460]: Error [Shut down address: akka.tcp://VotingServiceSpec@localhost:60460] [

[JVM-3] [INFO] [05/25/2017 13:26:48.246] [VotingServiceSpec-akka.remote.default-remote-dispatcher-6] [akka.tcp://VotingServiceSpec@localhost:60460/system/remoting-terminator] Shutting down remote daemon.

[JVM-3] [INFO] [05/25/2017 13:26:48.262] [VotingServiceSpec-akka.remote.default-remote-dispatcher-6] [akka.tcp://VotingServiceSpec@localhost:60460/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports.

[JVM-3] [INFO] [05/25/2017 13:26:48.324] [VotingServiceSpec-akka.actor.default-dispatcher-3] [akka.remote.Remoting] Remoting shut down

[JVM-3] [INFO] [05/25/2017 13:26:48.324] [VotingServiceSpec-akka.remote.default-remote-dispatcher-7] [akka.tcp://VotingServiceSpec@localhost:60460/system/remoting-terminator] Remoting shut down.

[JVM-3] Run completed in 7 seconds, 609 milliseconds.

[JVM-3] Total number of tests run: 2

[JVM-3] Suites: completed 1, aborted 0

[JVM-3] Tests: succeeded 2, failed 0, canceled 0, ignored 0, pending 0

[JVM-3] All tests passed.

[JVM-1] [ERROR] [05/25/2017 13:26:48.293] [VotingServiceSpec-akka.remote.default-remote-dispatcher-18] [akka.tcp://VotingServiceSpec@localhost:60461/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A60460-0/endpointWriter] AssociationError [akka.tcp://VotingServiceSpec@localhost:60461] <- [akka.tcp://VotingServiceSpec@localhost:60460]: Error [Shut down address: akka.tcp://VotingServiceSpec@localhost:60460] [

[JVM-1] akka.remote.ShutDownAssociation: Shut down address: akka.tcp://VotingServiceSpec@localhost:60460

[JVM-1] Caused by: akka.remote.transport.Transport$InvalidAssociationException: The remote system terminated the association because it is shutting down.

[JVM-1] ]

[JVM-2] akka.remote.ShutDownAssociation: Shut down address: akka.tcp://VotingServiceSpec@localhost:60460

[JVM-1] [ERROR] [05/25/2017 13:26:48.355] [VotingServiceSpec-akka.remote.default-remote-dispatcher-18] [akka.tcp://VotingServiceSpec@localhost:60461/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A60462-1/endpointWriter] AssociationError [akka.tcp://VotingServiceSpec@localhost:60461] <- [akka.tcp://VotingServiceSpec@localhost:60462]: Error [Shut down address: akka.tcp://VotingServiceSpec@localhost:60462] [

[JVM-2] Caused by: akka.remote.transport.Transport$InvalidAssociationException: The remote system terminated the association because it is shutting down.

[JVM-1] akka.remote.ShutDownAssociation: Shut down address: akka.tcp://VotingServiceSpec@localhost:60462

[JVM-1] Caused by: akka.remote.transport.Transport$InvalidAssociationException: The remote system terminated the association because it is shutting down.

[JVM-1] ]

[JVM-1] [WARN] [05/25/2017 13:26:48.355] [VotingServiceSpec-akka.actor.default-dispatcher-6] [akka://VotingServiceSpec/deadLetters] received dead letter from Actor[akka://VotingServiceSpec/system/cluster/core/daemon/heartbeatSender#314949991]: Heartbeat(akka.tcp://VotingServiceSpec@localhost:60461)

[JVM-1] [WARN] [05/25/2017 13:26:48.355] [VotingServiceSpec-akka.actor.default-dispatcher-2] [akka://VotingServiceSpec/deadLetters] received dead letter from Actor[akka://VotingServiceSpec/system/cluster/core/daemon/heartbeatSender#314949991]: Heartbeat(akka.tcp://VotingServiceSpec@localhost:60461)

[JVM-1] [WARN] [05/25/2017 13:26:48.371] [VotingServiceSpec-akka.actor.default-dispatcher-6] [akka://VotingServiceSpec/user/controller/127.0.0.1:60488-server2] received dead letter from Actor[akka://VotingServiceSpec/deadLetters]: ClientDisconnected

[JVM-1] [INFO] [05/25/2017 13:26:48.371] [VotingServiceSpec-akka.remote.default-remote-dispatcher-10] [akka.tcp://VotingServiceSpec@localhost:60461/system/remoting-terminator] Shutting down remote daemon.

[JVM-1] [INFO] [05/25/2017 13:26:48.402] [VotingServiceSpec-akka.actor.default-dispatcher-8] [akka.remote.Remoting] Remoting shut down

[JVM-1] [INFO] [05/25/2017 13:26:48.418] [VotingServiceSpec-akka.remote.default-remote-dispatcher-18] [akka.tcp://VotingServiceSpec@localhost:60461/system/remoting-terminator] Remoting shut down.

[JVM-1] Run completed in 7 seconds, 499 milliseconds.

[JVM-1] Total number of tests run: 2

[JVM-1] Suites: completed 1, aborted 0

[JVM-1] Tests: succeeded 2, failed 0, canceled 0, ignored 0, pending 0

[JVM-1] All tests passed.

[JVM-2] ]

[JVM-2] [WARN] [05/25/2017 13:26:48.324] [VotingServiceSpec-akka.actor.default-dispatcher-2] [akka://VotingServiceSpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A60460-1/endpointWriter] received dead letter from Actor[akka://VotingServiceSpec/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FVotingServiceSpec%40localhost%3A60460-1/endpointWriter#-2075068883]: AckIdleCheckTimer

[JVM-2] [INFO] [05/25/2017 13:26:48.324] [VotingServiceSpec-akka.remote.default-remote-dispatcher-8] [akka.tcp://VotingServiceSpec@localhost:60462/system/remoting-terminator] Shutting down remote daemon.

[JVM-2] [INFO] [05/25/2017 13:26:48.340] [VotingServiceSpec-akka.remote.default-remote-dispatcher-8] [akka.tcp://VotingServiceSpec@localhost:60462/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports.

[JVM-2] [INFO] [05/25/2017 13:26:48.371] [VotingServiceSpec-akka.actor.default-dispatcher-3] [akka.remote.Remoting] Remoting shut down

[JVM-2] [INFO] [05/25/2017 13:26:48.371] [VotingServiceSpec-akka.remote.default-remote-dispatcher-16] [akka.tcp://VotingServiceSpec@localhost:60462/system/remoting-terminator] Remoting shut down.

[JVM-2] Run completed in 7 seconds, 734 milliseconds.

[JVM-2] Total number of tests run: 2

[JVM-2] Suites: completed 1, aborted 0

[JVM-2] Tests: succeeded 2, failed 0, canceled 0, ignored 0, pending 0

[JVM-2] All tests passed.

[info] Passed: Total 3, Failed 0, Errors 0, Passed 3

[success] Total time: 20 s, completed May 25, 2017 1:26:48 PM

To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscribe@googlegroups.com.

To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

--

Patrik Nordwall
Akka Tech Lead
Lightbend - Reactive apps on the JVM
Twitter: @patriknw

--
>>>>>>>>>> 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 a topic in the Google Groups "Akka User List" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/akka-user/2OnoPDUa6VU/unsubscribe.

To unsubscribe from this group and all its topics, send an email to akka-user+unsubscribe@googlegroups.com.

To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

--
Mainak Ghosh

--
>>>>>>>>>> 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 akka-user+unsubscribe@googlegroups.com.

To post to this group, send email to akka...@googlegroups.com.
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 a topic in the Google Groups "Akka User List" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/akka-user/2OnoPDUa6VU/unsubscribe.

To unsubscribe from this group and all its topics, send an email to akka-user+unsubscribe@googlegroups.com.

To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Mainak Ghosh

Patrik Nordwall

unread,

May 26, 2017, 7:24:59 AM5/26/17

to akka...@googlegroups.com

That is the right property. There is no such exception in the logs you shared, and I have tried it myself.