search

uzh / signal-collect

A framework for scalable graph computing.
www.signalcollect.com
Apache License 2.0
148 stars 32 forks source link

"Undeliverable signal" when running GameOfLife example #131

Closed cshapeshifter closed 11 years ago

cshapeshifter commented 11 years ago

When running the GameOfLife example (even without interactive execution and without console), the execution crashes immediately on the first signal step with the following exceptions which repeat indefinitely:

shapeshifter@tachychineta> head -n 300 temp.log
Adding vertices ...
Adding edges ...
Unhandled error: Some(SignalMessage((10,9),Some((9,9)),0))
Unhandled error: Some(SignalMessage((10,8),Some((9,9)),0))
Unhandled error: Some(SignalMessage((10,1),Some((9,1)),1))
Unhandled error: Some(SignalMessage((8,10),Some((9,9)),0))
Worker 0 crashed with java.lang.Exception: Undeliverable signal: 1 from Some((9,1)) could not be delivered to (10,1) because of null or reason Undeliverable signal: 1 from Some((9,1)) could not be delivered to (10,1) at position com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:95)
com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:94)
com.signalcollect.worker.WorkerImplementation.processSignal(WorkerImplementation.scala:165)
com.signalcollect.worker.AkkaWorker$$anonfun$receive$1.applyOrElse(AkkaWorker.scala:153)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
akka.actor.ActorCell.invoke(ActorCell.scala:386)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
akka.dispatch.Mailbox.run(Mailbox.scala:212)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:722)
, not recoverable.
Worker 2 crashed with java.lang.Exception: Undeliverable signal: 0 from Some((9,9)) could not be delivered to (10,9) because of null or reason Undeliverable signal: 0 from Some((9,9)) could not be delivered to (10,9) at position com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:95)
com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:94)
com.signalcollect.worker.WorkerImplementation.processSignal(WorkerImplementation.scala:165)
com.signalcollect.worker.AkkaWorker$$anonfun$receive$1.applyOrElse(AkkaWorker.scala:153)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
akka.actor.ActorCell.invoke(ActorCell.scala:386)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
akka.dispatch.Mailbox.run(Mailbox.scala:212)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:722)
, not recoverable.
Worker 1 crashed with java.lang.Exception: Undeliverable signal: 0 from Some((9,9)) could not be delivered to (8,10) because of null or reason Undeliverable signal: 0 from Some((9,9)) could not be delivered to (8,10) at position com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:95)
com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:94)
com.signalcollect.worker.WorkerImplementation.processSignal(WorkerImplementation.scala:165)
com.signalcollect.worker.AkkaWorker$$anonfun$receive$1.applyOrElse(AkkaWorker.scala:153)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
akka.actor.ActorCell.invoke(ActorCell.scala:386)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
akka.dispatch.Mailbox.run(Mailbox.scala:212)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:722)
, not recoverable.
Worker 3 crashed with java.lang.Exception: Undeliverable signal: 0 from Some((9,9)) could not be delivered to (10,8) because of null or reason Undeliverable signal: 0 from Some((9,9)) could not be delivered to (10,8) at position com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:95)
com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:94)
com.signalcollect.worker.WorkerImplementation.processSignal(WorkerImplementation.scala:165)
com.signalcollect.worker.AkkaWorker$$anonfun$receive$1.applyOrElse(AkkaWorker.scala:153)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
akka.actor.ActorCell.invoke(ActorCell.scala:386)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
akka.dispatch.Mailbox.run(Mailbox.scala:212)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:722)
, not recoverable.
Unhandled error: Some(SignalMessage((9,2),Some((9,1)),1))
Unhandled error: Some(SignalMessage((8,0),Some((9,1)),1))
Unhandled error: Some(SignalMessage((0,7),Some((1,6)),0))
Unhandled error: Some(SignalMessage((9,0),Some((9,1)),1))
Worker 1 crashed with java.lang.Exception: Undeliverable signal: 1 from Some((9,1)) could not be delivered to (9,2) because of null or reason Undeliverable signal: 1 from Some((9,1)) could not be delivered to (9,2) at position com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:95)
com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:94)
com.signalcollect.worker.WorkerImplementation.processSignal(WorkerImplementation.scala:165)
com.signalcollect.worker.AkkaWorker$$anonfun$receive$1.applyOrElse(AkkaWorker.scala:153)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
akka.actor.ActorCell.invoke(ActorCell.scala:386)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
akka.dispatch.Mailbox.run(Mailbox.scala:212)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:722)
, not recoverable.
Worker 0 crashed with java.lang.Exception: Undeliverable signal: 1 from Some((9,1)) could not be delivered to (8,0) because of null or reason Undeliverable signal: 1 from Some((9,1)) could not be delivered to (8,0) at position com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:95)
com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:94)
com.signalcollect.worker.WorkerImplementation.processSignal(WorkerImplementation.scala:165)
com.signalcollect.worker.AkkaWorker$$anonfun$receive$1.applyOrElse(AkkaWorker.scala:153)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
akka.actor.ActorCell.invoke(ActorCell.scala:386)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
akka.dispatch.Mailbox.run(Mailbox.scala:212)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:722)
, not recoverable.
Worker 3 crashed with java.lang.Exception: Undeliverable signal: 0 from Some((1,6)) could not be delivered to (0,7) because of null or reason Undeliverable signal: 0 from Some((1,6)) could not be delivered to (0,7) at position com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:95)
com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:94)
com.signalcollect.worker.WorkerImplementation.processSignal(WorkerImplementation.scala:165)
com.signalcollect.worker.AkkaWorker$$anonfun$receive$1.applyOrElse(AkkaWorker.scala:153)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
akka.actor.ActorCell.invoke(ActorCell.scala:386)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
akka.dispatch.Mailbox.run(Mailbox.scala:212)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:722)
, not recoverable.
Worker 2 crashed with java.lang.Exception: Undeliverable signal: 1 from Some((9,1)) could not be delivered to (9,0) because of null or reason Undeliverable signal: 1 from Some((9,1)) could not be delivered to (9,0) at position com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:95)
com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:94)
com.signalcollect.worker.WorkerImplementation.processSignal(WorkerImplementation.scala:165)
com.signalcollect.worker.AkkaWorker$$anonfun$receive$1.applyOrElse(AkkaWorker.scala:153)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
akka.actor.ActorCell.invoke(ActorCell.scala:386)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
akka.dispatch.Mailbox.run(Mailbox.scala:212)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:722)
, not recoverable.
Unhandled error: Some(SignalMessage((8,8),Some((7,7)),1))
Unhandled error: Some(SignalMessage((8,1),Some((9,1)),1))
Unhandled error: Some(SignalMessage((1,7),Some((1,6)),0))
Unhandled error: Some(SignalMessage((8,9),Some((9,9)),0))
Worker 1 crashed with java.lang.Exception: Undeliverable signal: 1 from Some((7,7)) could not be delivered to (8,8) because of null or reason Undeliverable signal: 1 from Some((7,7)) could not be delivered to (8,8) at position com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:95)
com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:94)
com.signalcollect.worker.WorkerImplementation.processSignal(WorkerImplementation.scala:165)
com.signalcollect.worker.AkkaWorker$$anonfun$receive$1.applyOrElse(AkkaWorker.scala:153)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
akka.actor.ActorCell.invoke(ActorCell.scala:386)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
akka.dispatch.Mailbox.run(Mailbox.scala:212)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:722)
, not recoverable.
Unhandled error: Some(SignalMessage((8,7),Some((7,7)),1))
Worker 0 crashed with java.lang.Exception: Undeliverable signal: 0 from Some((9,9)) could not be delivered to (8,9) because of null or reason Undeliverable signal: 0 from Some((9,9)) could not be delivered to (8,9) at position com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:95)
com.signalcollect.worker.AkkaWorker$$anonfun$2.apply(AkkaWorker.scala:94)
com.signalcollect.worker.WorkerImplementation.processSignal(WorkerImplementation.scala:165)
com.signalcollect.worker.AkkaWorker$$anonfun$receive$1.applyOrElse(AkkaWorker.scala:153)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:425)
akka.actor.ActorCell.invoke(ActorCell.scala:386)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230)
akka.dispatch.Mailbox.run(Mailbox.scala:212)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:722)
, not recoverable.
troxler commented 11 years ago

Fixed by https://github.com/uzh/signal-collect/commit/0e065506f21a79c3627d0d8e0bc59263637e6efe.

@pstutz FYI: Reverted your change https://github.com/uzh/signal-collect/commit/e14d16a32cb7ec59fe07c253cdaf7c007e25093a as that introduced this bug.