Hi, I saw the same issue as this thread, http://apache-spark-user-list.1001560.n3.nabble.com/Spark-1-0-1-akka-connection-refused-td9864.html
Anyone has a fix for this bug? Please?! The log info in my worker node is like, 14/10/30 20:15:18 INFO Worker: Asked to kill executor app-20141030201514-0000/0 14/10/30 20:15:18 INFO ExecutorRunner: Runner thread for executor app-20141030201514-0000/0 interrupted 14/10/30 20:15:18 INFO ExecutorRunner: Killing process! 14/10/30 20:15:18 INFO Worker: Executor app-20141030201514-0000/0 finished with state KILLED exitStatus 1 14/10/30 20:15:18 INFO LocalActorRef: Message [akka.remote.transport.ActorTransportAdapter$DisassociateUnderlying] from Actor[akka://sparkWorker/deadLetters] to Actor[akka://sparkWorker/system/transports/akkaprotocolmanager.tcp0/akkaProtocol-tcp%3A%2F%2FsparkWorker%4010.180.49.228%3A47087-2#-814958390] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. 14/10/30 20:15:18 ERROR EndpointWriter: AssociationError [akka.tcp://sparkWorker@node001:42816] -> [akka.tcp://sparkExecutor@node001:35811]: Error [Association failed with [akka.tcp://sparkExecutor@node001:35811]] [ akka.remote.EndpointAssociationException: Association failed with [akka.tcp://sparkExecutor@node001:35811] Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: node001/10.180.49.228:35811 ] 14/10/30 20:15:18 ERROR EndpointWriter: AssociationError [akka.tcp://sparkWorker@node001:42816] -> [akka.tcp://sparkExecutor@node001:35811]: Error [Association failed with [akka.tcp://sparkExecutor@node001:35811]] [ akka.remote.EndpointAssociationException: Association failed with [akka.tcp://sparkExecutor@node001:35811] Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: node001/10.180.49.228:35811 ] 14/10/30 20:15:18 ERROR EndpointWriter: AssociationError [akka.tcp://sparkWorker@node001:42816] -> [akka.tcp://sparkExecutor@node001:35811]: Error [Association failed with [akka.tcp://sparkExecutor@node001:35811]] [ akka.remote.EndpointAssociationException: Association failed with [akka.tcp://sparkExecutor@node001:35811] Caused by: akka.remote.transport.netty.NettyTransport$$anonfun$associate$1$$anon$2: Connection refused: node001/10.180.49.228:35811 -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/akka-connection-refused-bug-fix-tp17764.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org