[ https://issues.apache.org/jira/browse/SPARK-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Josh Rosen resolved SPARK-4212. ------------------------------- Resolution: Cannot Reproduce Resolving as "cannot reproduce" since this is really old. > 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