Re: [akka-user] received Supervise from unregistered child ... this will not end well
Hi Marco,
you'll need to update all Akka dependencies to the 2.3.9 version and make
sure that your dependencies that depend on akka transitively are built for
Akka 2.3.x
On Thu, Jan 22, 2015 at 11:57 AM, Marco Luca Sbodio
wrote:
> Hi Viktor,
>
> after upgrading to akka 2.3.9 my multi-jvm-test crashes with this error:
>
> 10:49:07.654UTC ERROR
> [MySystemMultiNodeTest-akka.actor.default-dispatcher-21]
> [akka.actor.ActorSystemImpl] [ActorSystem(MySystemMultiNodeTest)] -
> Uncaught error from thread
> [MySystemMultiNodeTest-akka.actor.default-dispatcher-21] shutting down JVM
> since 'akka.jvm-exit-on-fatal-error' is enabled
> java.lang.AbstractMethodError: akka/actor/Actor.aroundPreStart()V
> at akka.actor.ActorCell.create(ActorCell.scala:580)
> ~[akka-actor_2.10-2.3.9.jar:na]
> at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
> ~[akka-actor_2.10-2.3.9.jar:na]
> at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
> ~[akka-actor_2.10-2.3.9.jar:na]
> at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279)
> [akka-actor_2.10-2.3.9.jar:na]
> at akka.dispatch.Mailbox.run(Mailbox.scala:220)
> [akka-actor_2.10-2.3.9.jar:na]
> at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
> [akka-actor_2.10-2.3.9.jar:na]
> at
> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> [scala-library-2.10.4.jar:na]
> at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> [scala-library-2.10.4.jar:na]
> at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> [scala-library-2.10.4.jar:na]
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> [scala-library-2.10.4.jar:na]
>
> Has something change with multi-jvm/multi-node testing from akka 2.2.4 to
> akka 2.3.9?
> Any clue?
>
> Thank you in advance,
> Marco
>
> On Wednesday, 21 January 2015 19:15:51 UTC, √ wrote:
>>
>> Hi Marco,
>>
>> Please upgrade to 2.3.9 if you haven't already, there was a couple of
>> remoting-related issues fixed there.
>>
>> On Wed, Jan 21, 2015 at 6:45 PM, Marco Luca Sbodio
>> wrote:
>>
>>> I haven't.
>>>
>>> I've managed to figure out that sometimes the following code
>>>
>>> [[
>>> int nextStepNumber = planSteps[0].getStepNumber();
>>> Address nextAddress = planSteps[0].getPeer().
>>> getAddress();
>>> PlanStep[] nextPlanSteps = new
>>> PlanStep[planSteps.length];
>>> System.arraycopy(planSteps, 0, nextPlanSteps, 0,
>>> planSteps.length);
>>> firstWorker = getContext().actorOf(
>>> Worker.mkProps(sink,
>>> nextPlanSteps).withDeploy(new Deploy(new RemoteScope(nextAddress))),
>>> Worker.actorName + nextStepNumber);
>>> firstWorker.tell(CommonApi.START, getSelf());
>>> log.debug("started first worker");
>>> Chunk chunk = new Chunk(0, new byte[] {});
>>>
>>> firstWorker.tell(chunk, getSelf());
>>> log.debug("empty chunk sent to first worker");
>>> ]]
>>>
>>> generate such an error:
>>>
>>> [[
>>> 17:20:08.195UTC ERROR
>>> [MySystemMultiNodeTest-akka.actor.default-dispatcher-16]
>>> [org.mysystem.actor.SubPlanner] [akka://MySystemMultiNodeTest/
>>> user/the-engine/executor-6eb81c68-e91d-47cd-bb26-
>>> be53eee90f63/planner/sub-planner-11] - received Supervise from
>>> unregistered child Actor[akka.tcp://MySystemMulti
>>> nodet...@nd06.domain.com:3002/remote/akka.tcp/
>>> mysystemmultinodet...@nd03.domain.com:3001/user/the-
>>> engine/executor-6eb81c68-e91d-47cd-bb26-be53eee90f63/
>>> planner/sub-planner-11/worker0#-1680645824], this will not end well
>>> ]]
>>>
>>> tracing back "sub-planner-11" in my logs I find the two messages
>>> log.debug("started first worker");
>>> firstWorker.tell(chunk, getSelf());
>>>
>>> and then I get the error ... and I have no clue why
>>>
>>> Thank you in advance for any help/suggestion.
>>>
>>> Cheers,
>>> Marco
>>>
>>> On Tuesday, 20 January 2015 18:12:08 UTC, √ wrote:
Have you closed over "context.actorOf" and execute it within a Future
or similar?
On Tue, Jan 20, 2015 at 6:47 PM, Marco Luca Sbodio >>> > wrote:
> Hello everyone,
>
> while testing my system I'm randomly getting error messages similar to
> the one in the subject of this topic. Here's an example:
>
> 17:27:59.265UTC ERROR
> [MySystemMultiNodeTest-akka.actor.default-dispatcher-16]
> [org.mysystem.actor.Worker] [akka://MySystemMultiNodeTest/
> user/the-engine/executor-7b7690ee-f31d-45f1-93ef-79cba01fe60
> 4/planner/sub-planner-951/worker0] - received Supervise from
> unregistered child Actor[akka.tcp://MySystemMulti
> nodet...@nd06.domain.com:3002/remote/akka.tcp/MySystemMultiN
> odet...@nd03.domain.com:3001/user/the-engine/executor-7b7690ee-f31d-
> 45f1-93ef-79cba01fe60
Re: [akka-user] received Supervise from unregistered child ... this will not end well
Hi Viktor,
after upgrading to akka 2.3.9 my multi-jvm-test crashes with this error:
10:49:07.654UTC ERROR
[MySystemMultiNodeTest-akka.actor.default-dispatcher-21]
[akka.actor.ActorSystemImpl] [ActorSystem(MySystemMultiNodeTest)] -
Uncaught error from thread
[MySystemMultiNodeTest-akka.actor.default-dispatcher-21] shutting down JVM
since 'akka.jvm-exit-on-fatal-error' is enabled
java.lang.AbstractMethodError: akka/actor/Actor.aroundPreStart()V
at akka.actor.ActorCell.create(ActorCell.scala:580)
~[akka-actor_2.10-2.3.9.jar:na]
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
~[akka-actor_2.10-2.3.9.jar:na]
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
~[akka-actor_2.10-2.3.9.jar:na]
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279)
[akka-actor_2.10-2.3.9.jar:na]
at akka.dispatch.Mailbox.run(Mailbox.scala:220)
[akka-actor_2.10-2.3.9.jar:na]
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
[akka-actor_2.10-2.3.9.jar:na]
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
[scala-library-2.10.4.jar:na]
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
[scala-library-2.10.4.jar:na]
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
[scala-library-2.10.4.jar:na]
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[scala-library-2.10.4.jar:na]
Has something change with multi-jvm/multi-node testing from akka 2.2.4 to
akka 2.3.9?
Any clue?
Thank you in advance,
Marco
On Wednesday, 21 January 2015 19:15:51 UTC, √ wrote:
>
> Hi Marco,
>
> Please upgrade to 2.3.9 if you haven't already, there was a couple of
> remoting-related issues fixed there.
>
> On Wed, Jan 21, 2015 at 6:45 PM, Marco Luca Sbodio > wrote:
>
>> I haven't.
>>
>> I've managed to figure out that sometimes the following code
>>
>> [[
>> int nextStepNumber = planSteps[0].getStepNumber();
>> Address nextAddress = planSteps[0].getPeer().getAddress();
>> PlanStep[] nextPlanSteps = new PlanStep[planSteps.length];
>> System.arraycopy(planSteps, 0, nextPlanSteps, 0,
>> planSteps.length);
>> firstWorker = getContext().actorOf(
>> Worker.mkProps(sink,
>> nextPlanSteps).withDeploy(new Deploy(new RemoteScope(nextAddress))),
>> Worker.actorName + nextStepNumber);
>> firstWorker.tell(CommonApi.START, getSelf());
>> log.debug("started first worker");
>> Chunk chunk = new Chunk(0, new byte[] {});
>> firstWorker.tell(chunk, getSelf());
>> log.debug("empty chunk sent to first worker");
>> ]]
>>
>> generate such an error:
>>
>> [[
>> 17:20:08.195UTC ERROR
>> [MySystemMultiNodeTest-akka.actor.default-dispatcher-16]
>> [org.mysystem.actor.SubPlanner]
>> [akka://MySystemMultiNodeTest/user/the-engine/executor-6eb81c68-e91d-47cd-bb26-be53eee90f63/planner/sub-planner-11]
>>
>> - received Supervise from unregistered child Actor[akka.tcp://
>> mysystemmultinodet...@nd06.domain.com:3002/remote/akka.tcp/mysystemmultinodet...@nd03.domain.com:3001/user/the-engine/executor-6eb81c68-e91d-47cd-bb26-be53eee90f63/planner/sub-planner-11/worker0#-1680645824],
>>
>> this will not end well
>> ]]
>>
>> tracing back "sub-planner-11" in my logs I find the two messages
>> log.debug("started first worker");
>> firstWorker.tell(chunk, getSelf());
>>
>> and then I get the error ... and I have no clue why
>>
>> Thank you in advance for any help/suggestion.
>>
>> Cheers,
>> Marco
>>
>> On Tuesday, 20 January 2015 18:12:08 UTC, √ wrote:
>>>
>>> Have you closed over "context.actorOf" and execute it within a Future or
>>> similar?
>>>
>>> On Tue, Jan 20, 2015 at 6:47 PM, Marco Luca Sbodio
>>> wrote:
>>>
Hello everyone,
while testing my system I'm randomly getting error messages similar to
the one in the subject of this topic. Here's an example:
17:27:59.265UTC ERROR
[MySystemMultiNodeTest-akka.actor.default-dispatcher-16]
[org.mysystem.actor.Worker] [akka://MySystemMultiNodeTest/
user/the-engine/executor-7b7690ee-f31d-45f1-93ef-
79cba01fe604/planner/sub-planner-951/worker0] - received Supervise
from unregistered child Actor[akka.tcp://MySystemMulti
nodet...@nd06.domain.com:3002/remote/akka.tcp/
mysystemmultinodet...@nd03.domain.com:3001/user/the-
engine/executor-7b7690ee-f31d-45f1-93ef-79cba01fe604/
planner/sub-planner-951/worker0/worker1.4#-430862452], this will not
end well
I really have no clue what might cause these errors, and what the
consequences are ("this will not end well"). I've tried searching on the
Web, but didn't find anything that helped me.
I'm using akka 2.2.3
Any help is highly appre
Re: [akka-user] received Supervise from unregistered child ... this will not end well
Hi Marco,
Please upgrade to 2.3.9 if you haven't already, there was a couple of
remoting-related issues fixed there.
On Wed, Jan 21, 2015 at 6:45 PM, Marco Luca Sbodio
wrote:
> I haven't.
>
> I've managed to figure out that sometimes the following code
>
> [[
> int nextStepNumber = planSteps[0].getStepNumber();
> Address nextAddress = planSteps[0].getPeer().getAddress();
> PlanStep[] nextPlanSteps = new PlanStep[planSteps.length];
> System.arraycopy(planSteps, 0, nextPlanSteps, 0,
> planSteps.length);
> firstWorker = getContext().actorOf(
> Worker.mkProps(sink, nextPlanSteps).withDeploy(new
> Deploy(new RemoteScope(nextAddress))),
> Worker.actorName + nextStepNumber);
> firstWorker.tell(CommonApi.START, getSelf());
> log.debug("started first worker");
> Chunk chunk = new Chunk(0, new byte[] {});
> firstWorker.tell(chunk, getSelf());
> log.debug("empty chunk sent to first worker");
> ]]
>
> generate such an error:
>
> [[
> 17:20:08.195UTC ERROR
> [MySystemMultiNodeTest-akka.actor.default-dispatcher-16]
> [org.mysystem.actor.SubPlanner]
> [akka://MySystemMultiNodeTest/user/the-engine/executor-6eb81c68-e91d-47cd-bb26-be53eee90f63/planner/sub-planner-11]
> - received Supervise from unregistered child Actor[akka.tcp://
> mysystemmultinodet...@nd06.domain.com:3002/remote/akka.tcp/mysystemmultinodet...@nd03.domain.com:3001/user/the-engine/executor-6eb81c68-e91d-47cd-bb26-be53eee90f63/planner/sub-planner-11/worker0#-1680645824],
> this will not end well
> ]]
>
> tracing back "sub-planner-11" in my logs I find the two messages
> log.debug("started first worker");
> firstWorker.tell(chunk, getSelf());
>
> and then I get the error ... and I have no clue why
>
> Thank you in advance for any help/suggestion.
>
> Cheers,
> Marco
>
> On Tuesday, 20 January 2015 18:12:08 UTC, √ wrote:
>>
>> Have you closed over "context.actorOf" and execute it within a Future or
>> similar?
>>
>> On Tue, Jan 20, 2015 at 6:47 PM, Marco Luca Sbodio
>> wrote:
>>
>>> Hello everyone,
>>>
>>> while testing my system I'm randomly getting error messages similar to
>>> the one in the subject of this topic. Here's an example:
>>>
>>> 17:27:59.265UTC ERROR
>>> [MySystemMultiNodeTest-akka.actor.default-dispatcher-16]
>>> [org.mysystem.actor.Worker] [akka://MySystemMultiNodeTest/
>>> user/the-engine/executor-7b7690ee-f31d-45f1-93ef-
>>> 79cba01fe604/planner/sub-planner-951/worker0] - received Supervise from
>>> unregistered child Actor[akka.tcp://MySystemMulti
>>> nodet...@nd06.domain.com:3002/remote/akka.tcp/
>>> mysystemmultinodet...@nd03.domain.com:3001/user/the-
>>> engine/executor-7b7690ee-f31d-45f1-93ef-79cba01fe604/
>>> planner/sub-planner-951/worker0/worker1.4#-430862452], this will not
>>> end well
>>>
>>> I really have no clue what might cause these errors, and what the
>>> consequences are ("this will not end well"). I've tried searching on the
>>> Web, but didn't find anything that helped me.
>>>
>>> I'm using akka 2.2.3
>>>
>>> Any help is highly appreciated!
>>>
>>> Thanks,
>>> Marco
>>>
>>> --
>>> >> 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+...@googlegroups.com.
>>> To post to this group, send email to akka...@googlegroups.com.
>>> 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 akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> 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 a
Re: [akka-user] received Supervise from unregistered child ... this will not end well
I haven't.
I've managed to figure out that sometimes the following code
[[
int nextStepNumber = planSteps[0].getStepNumber();
Address nextAddress = planSteps[0].getPeer().getAddress();
PlanStep[] nextPlanSteps = new PlanStep[planSteps.length];
System.arraycopy(planSteps, 0, nextPlanSteps, 0,
planSteps.length);
firstWorker = getContext().actorOf(
Worker.mkProps(sink, nextPlanSteps).withDeploy(new
Deploy(new RemoteScope(nextAddress))),
Worker.actorName + nextStepNumber);
firstWorker.tell(CommonApi.START, getSelf());
log.debug("started first worker");
Chunk chunk = new Chunk(0, new byte[] {});
firstWorker.tell(chunk, getSelf());
log.debug("empty chunk sent to first worker");
]]
generate such an error:
[[
17:20:08.195UTC ERROR
[MySystemMultiNodeTest-akka.actor.default-dispatcher-16]
[org.mysystem.actor.SubPlanner]
[akka://MySystemMultiNodeTest/user/the-engine/executor-6eb81c68-e91d-47cd-bb26-be53eee90f63/planner/sub-planner-11]
- received Supervise from unregistered child
Actor[akka.tcp://mysystemmultinodet...@nd06.domain.com:3002/remote/akka.tcp/mysystemmultinodet...@nd03.domain.com:3001/user/the-engine/executor-6eb81c68-e91d-47cd-bb26-be53eee90f63/planner/sub-planner-11/worker0#-1680645824],
this will not end well
]]
tracing back "sub-planner-11" in my logs I find the two messages
log.debug("started first worker");
firstWorker.tell(chunk, getSelf());
and then I get the error ... and I have no clue why
Thank you in advance for any help/suggestion.
Cheers,
Marco
On Tuesday, 20 January 2015 18:12:08 UTC, √ wrote:
>
> Have you closed over "context.actorOf" and execute it within a Future or
> similar?
>
> On Tue, Jan 20, 2015 at 6:47 PM, Marco Luca Sbodio > wrote:
>
>> Hello everyone,
>>
>> while testing my system I'm randomly getting error messages similar to
>> the one in the subject of this topic. Here's an example:
>>
>> 17:27:59.265UTC ERROR
>> [MySystemMultiNodeTest-akka.actor.default-dispatcher-16]
>> [org.mysystem.actor.Worker]
>> [akka://MySystemMultiNodeTest/user/the-engine/executor-7b7690ee-f31d-45f1-93ef-79cba01fe604/planner/sub-planner-951/worker0]
>>
>> - received Supervise from unregistered child Actor[akka.tcp://
>> mysystemmultinodet...@nd06.domain.com:3002/remote/akka.tcp/mysystemmultinodet...@nd03.domain.com:3001/user/the-engine/executor-7b7690ee-f31d-45f1-93ef-79cba01fe604/planner/sub-planner-951/worker0/worker1.4#-430862452],
>>
>> this will not end well
>>
>> I really have no clue what might cause these errors, and what the
>> consequences are ("this will not end well"). I've tried searching on the
>> Web, but didn't find anything that helped me.
>>
>> I'm using akka 2.2.3
>>
>> Any help is highly appreciated!
>>
>> Thanks,
>> Marco
>>
>> --
>> >> 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+...@googlegroups.com .
>> To post to this group, send email to akka...@googlegroups.com
>> .
>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] received Supervise from unregistered child ... this will not end well
Have you closed over "context.actorOf" and execute it within a Future or
similar?
On Tue, Jan 20, 2015 at 6:47 PM, Marco Luca Sbodio
wrote:
> Hello everyone,
>
> while testing my system I'm randomly getting error messages similar to the
> one in the subject of this topic. Here's an example:
>
> 17:27:59.265UTC ERROR
> [MySystemMultiNodeTest-akka.actor.default-dispatcher-16]
> [org.mysystem.actor.Worker]
> [akka://MySystemMultiNodeTest/user/the-engine/executor-7b7690ee-f31d-45f1-93ef-79cba01fe604/planner/sub-planner-951/worker0]
> - received Supervise from unregistered child Actor[akka.tcp://
> mysystemmultinodet...@nd06.domain.com:3002/remote/akka.tcp/mysystemmultinodet...@nd03.domain.com:3001/user/the-engine/executor-7b7690ee-f31d-45f1-93ef-79cba01fe604/planner/sub-planner-951/worker0/worker1.4#-430862452],
> this will not end well
>
> I really have no clue what might cause these errors, and what the
> consequences are ("this will not end well"). I've tried searching on the
> Web, but didn't find anything that helped me.
>
> I'm using akka 2.2.3
>
> Any help is highly appreciated!
>
> Thanks,
> Marco
>
> --
> >> 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+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
