You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Josh Rosen (JIRA)" <ji...@apache.org> on 2016/01/05 22:15:39 UTC
[jira] [Resolved] (SPARK-4212) Actor not found
[ 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-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org