Davies Liu created SPARK-4212: --------------------------------- Summary: Actor not found Key: SPARK-4212 URL: https://issues.apache.org/jira/browse/SPARK-4212 Project: Spark Issue Type: Bug Components: Spark Core Affects Versions: 1.2.0 Reporter: Davies Liu
tried to run a PySpark test, but it hanged: NOTE: SPARK_PREPEND_CLASSES is set, placing locally compiled Spark classes ahead of assembly. 14/11/03 12:32:58 WARN Remoting: Tried to associate with unreachable remote address [akka.tcp://sparkDriver@dm:7077]. Address is now gated for 5000 ms, all messages to this address will be delivered to dead letters. Reason: Connection refused: dm/192.168.1.11:7077 14/11/03 12:32:58 ERROR OneForOneStrategy: Actor not found for: ActorSelection[Anchor(akka.tcp://sparkDriver@dm:7077/), Path(/user/HeartbeatReceiver)] akka.actor.ActorInitializationException: exception during creation at akka.actor.ActorInitializationException$.apply(Actor.scala:164) at akka.actor.ActorCell.create(ActorCell.scala:596) at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456) at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478) at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263) at akka.dispatch.Mailbox.run(Mailbox.scala:219) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393) at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Caused by: akka.actor.ActorNotFound: Actor not found for: ActorSelection[Anchor(akka.tcp://sparkDriver@dm:7077/), Path(/user/HeartbeatReceiver)] at akka.actor.ActorSelection$$anonfun$resolveOne$1.apply(ActorSelection.scala:65) at akka.actor.ActorSelection$$anonfun$resolveOne$1.apply(ActorSelection.scala:63) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67) at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82) at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) at akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58) at akka.dispatch.ExecutionContexts$sameThreadExecutionContext$.unbatchedExecute(Future.scala:74) at akka.dispatch.BatchingExecutor$class.execute(BatchingExecutor.scala:110) at akka.dispatch.ExecutionContexts$sameThreadExecutionContext$.execute(Future.scala:73) at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40) at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:248) at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:267) at akka.actor.EmptyLocalActorRef.specialHandle(ActorRef.scala:508) at akka.actor.DeadLetterActorRef.specialHandle(ActorRef.scala:541) at akka.actor.DeadLetterActorRef.$bang(ActorRef.scala:531) at akka.remote.RemoteActorRefProvider$RemoteDeadLetterActorRef.$bang(RemoteActorRefProvider.scala:87) at akka.remote.EndpointWriter.postStop(Endpoint.scala:561) at akka.actor.Actor$class.aroundPostStop(Actor.scala:475) at akka.remote.EndpointActor.aroundPostStop(Endpoint.scala:415) at akka.actor.dungeon.FaultHandling$class.akka$actor$dungeon$FaultHandling$$finishTerminate(FaultHandling.scala:210) at akka.actor.dungeon.FaultHandling$class.terminate(FaultHandling.scala:172) at akka.actor.ActorCell.terminate(ActorCell.scala:369) at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:462) ... 8 more ^CTraceback (most recent call last): File "python/pyspark/tests.py", line 1627, in <module> unittest.main() File "//anaconda/lib/python2.7/unittest/main.py", line 95, in __init__ self.runTests() File "//anaconda/lib/python2.7/unittest/main.py", line 232, in runTests self.result = testRunner.run(self.test) File "//anaconda/lib/python2.7/unittest/runner.py", line 151, in run test(result) File "//anaconda/lib/python2.7/unittest/suite.py", line 70, in __call__ return self.run(*args, **kwds) File "//anaconda/lib/python2.7/unittest/suite.py", line 108, in run test(result) File "//anaconda/lib/python2.7/unittest/suite.py", line 70, in __call__ return self.run(*args, **kwds) File "//anaconda/lib/python2.7/unittest/suite.py", line 100, in run self._handleClassSetUp(test, result) File "//anaconda/lib/python2.7/unittest/suite.py", line 146, in _handleClassSetUp setUpClass() File "python/pyspark/tests.py", line 801, in setUpClass cls.sc._jvm.WriteInputFormatTestDataGenerator.generateData(cls.tempdir.name, cls.sc._jsc) File "/Users/davies/work/spark/python/lib/py4j/java_gateway.py", line 536, in __call__ answer = self.gateway_client.send_command(command) File "/Users/davies/work/spark/python/lib/py4j/java_gateway.py", line 364, in send_command response = connection.send_command(command) File "/Users/davies/work/spark/python/lib/py4j/java_gateway.py", line 473, in send_command answer = smart_decode(self.stream.readline()[:-1]) File "//anaconda/lib/python2.7/socket.py", line 430, in readline data = recv(1) KeyboardInterrupt -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org