Re: [akka-user] Akka Distributed Data Sample thowing OversizedPayloadException

2017-05-25 Thread Patrik Nordwall 
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
tors 25 maj 2017 kl. 17:35 skrev Mainak Ghosh :

> Hello Patrik,
>
> Will this bug be fixed? Can you suggest me some quick work around?
>
> Thanks,
> Mainak
>
> On Wed, May 24, 2017 at 8:24 AM, Patrik Nordwall <
> patrik.nordw...@gmail.com> wrote:
>
>> 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
>>
>> On Tue, May 23, 2017 at 7:25 PM, Mainak Ghosh 
>> wrote:
>>
>>> 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

Re: [akka-user] Akka Distributed Data Sample thowing OversizedPayloadException

2017-05-25 Thread Mainak Ghosh 
Hello Patrik,

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

Thanks,
Mainak

On Wed, May 24, 2017 at 8:24 AM, Patrik Nordwall 
wrote:

> 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
>
> On Tue, May 23, 2017 at 7:25 PM, Mainak Ghosh 
> wrote:
>
>> 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]
>>

Re: [akka-user] Akka Distributed Data Sample thowing OversizedPayloadException

2017-05-24 Thread Patrik Nordwall 
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

On Tue, May 23, 2017 at 7:25 PM, Mainak Ghosh 
wrote:

> 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]
>

Re: [akka-user] Akka Distributed Data Sample thowing OversizedPayloadException

2017-05-23 Thread Mainak Ghosh 
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]

Re: [akka-user] Akka Distributed Data Sample thowing OversizedPayloadException

2017-05-23 Thread Patrik Nordwall 
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

On Tue, May 23, 2017 at 12:26 AM, Mainak Ghosh 
wrote:

> 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-user] Akka Distributed Data Sample thowing OversizedPayloadException

2017-05-22 Thread Mainak Ghosh 
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]