You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@spark.apache.org by Sujee Maniyam <su...@sujee.net> on 2014/08/17 08:04:55 UTC

akka error : play framework (2.3.3) and spark (1.0.2)

Hi

I am trying to connect to Spark from Play framework. Getting the following
Akka error...

[ERROR] [08/16/2014 17:12:05.249]
[spark-akka.actor.default-dispatcher-3] [ActorSystem(spark)] Uncaught
fatal error from thread [spark-akka.actor.default-dispatcher-3]
shutting down ActorSystem [spark]
java.lang.AbstractMethodError
  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)
  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)


full stack trace : https://gist.github.com/sujee/ff14fd602b76314e693d

source code here : https://github.com/sujee/play-spark-test

I have also found this thread mentioning Akka in-compatibility How to run
Play 2.2.x with Akka 2.3.x?
<http://stackoverflow.com/questions/22779882/how-to-run-play-2-2-x-with-akka-2-3-x>

Stack overflow thread :
http://stackoverflow.com/questions/25346657/akka-error-play-framework-2-3-3-and-spark-1-0-2

any suggestions?

thanks!

Sujee Maniyam (http://sujee.net | http://www.linkedin.com/in/sujeemaniyam )

Re: akka error : play framework (2.3.3) and spark (1.0.2)

Posted by Sujee Maniyam <su...@sujee.net>.
thanks Manu..

For me, the sample app works only in 'local' mode.
If I tried to connect a spark cluster (even one running locally :
spark://localhost:7077)  I get the following error

spark.master=spark://localhost:7077
[error] o.a.s.s.c.SparkDeploySchedulerBackend - Application has been
killed. Reason: Master removed our application: FAILED
[error] application -

! @6j8im8dfj - Internal server error, for (GET) [/] ->

play.api.Application$$anon$1: Execution exception[[SparkException: Job
aborted due to stage failure: Master removed our application: FAILED]]



Sujee Maniyam (http://sujee.net | http://www.linkedin.com/in/sujeemaniyam )


On Sat, Aug 16, 2014 at 11:15 PM, Manu Suryavansh <
suryavanshi.manu@gmail.com> wrote:

> Hi,
>
> I tried the Spark(1.0.0)+Play(2.3.3) example from the Knoldus blog -
> http://blog.knoldus.com/2014/06/18/play-with-spark-building-apache-spark-with-play-framework/ and
> it worked for me. The project is here -
> https://github.com/knoldus/Play-Spark-Scala
>
> Regards,
> Manu
>
>
> On Sat, Aug 16, 2014 at 11:04 PM, Sujee Maniyam <su...@sujee.net> wrote:
>
>> Hi
>>
>> I am trying to connect to Spark from Play framework. Getting the
>> following Akka error...
>>
>>
>> [ERROR] [08/16/2014 17:12:05.249] [spark-akka.actor.default-dispatcher-3] [ActorSystem(spark)] Uncaught fatal error from thread [spark-akka.actor.default-dispatcher-3] shutting down ActorSystem [spark]
>>
>> java.lang.AbstractMethodError
>>   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)
>>   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)
>>
>>
>> full stack trace : https://gist.github.com/sujee/ff14fd602b76314e693d
>>
>> source code here : https://github.com/sujee/play-spark-test
>>
>> I have also found this thread mentioning Akka in-compatibility How to
>> run Play 2.2.x with Akka 2.3.x?
>> <http://stackoverflow.com/questions/22779882/how-to-run-play-2-2-x-with-akka-2-3-x>
>>
>> Stack overflow thread :
>> http://stackoverflow.com/questions/25346657/akka-error-play-framework-2-3-3-and-spark-1-0-2
>>
>> any suggestions?
>>
>> thanks!
>>
>> Sujee Maniyam (http://sujee.net | http://www.linkedin.com/in/sujeemaniyam
>> )
>>
>
>
>
> --
> Manu Suryavansh
>

Re: akka error : play framework (2.3.3) and spark (1.0.2)

Posted by Sujee Maniyam <su...@sujee.net>.
thanks Manu..

For me, the sample app works only in 'local' mode.
If I tried to connect a spark cluster (even one running locally :
spark://localhost:7077)  I get the following error

spark.master=spark://localhost:7077
[error] o.a.s.s.c.SparkDeploySchedulerBackend - Application has been
killed. Reason: Master removed our application: FAILED
[error] application -

! @6j8im8dfj - Internal server error, for (GET) [/] ->

play.api.Application$$anon$1: Execution exception[[SparkException: Job
aborted due to stage failure: Master removed our application: FAILED]]



Sujee Maniyam (http://sujee.net | http://www.linkedin.com/in/sujeemaniyam )


On Sat, Aug 16, 2014 at 11:15 PM, Manu Suryavansh <
suryavanshi.manu@gmail.com> wrote:

> Hi,
>
> I tried the Spark(1.0.0)+Play(2.3.3) example from the Knoldus blog -
> http://blog.knoldus.com/2014/06/18/play-with-spark-building-apache-spark-with-play-framework/ and
> it worked for me. The project is here -
> https://github.com/knoldus/Play-Spark-Scala
>
> Regards,
> Manu
>
>
> On Sat, Aug 16, 2014 at 11:04 PM, Sujee Maniyam <su...@sujee.net> wrote:
>
>> Hi
>>
>> I am trying to connect to Spark from Play framework. Getting the
>> following Akka error...
>>
>>
>> [ERROR] [08/16/2014 17:12:05.249] [spark-akka.actor.default-dispatcher-3] [ActorSystem(spark)] Uncaught fatal error from thread [spark-akka.actor.default-dispatcher-3] shutting down ActorSystem [spark]
>>
>> java.lang.AbstractMethodError
>>   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)
>>   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)
>>
>>
>> full stack trace : https://gist.github.com/sujee/ff14fd602b76314e693d
>>
>> source code here : https://github.com/sujee/play-spark-test
>>
>> I have also found this thread mentioning Akka in-compatibility How to
>> run Play 2.2.x with Akka 2.3.x?
>> <http://stackoverflow.com/questions/22779882/how-to-run-play-2-2-x-with-akka-2-3-x>
>>
>> Stack overflow thread :
>> http://stackoverflow.com/questions/25346657/akka-error-play-framework-2-3-3-and-spark-1-0-2
>>
>> any suggestions?
>>
>> thanks!
>>
>> Sujee Maniyam (http://sujee.net | http://www.linkedin.com/in/sujeemaniyam
>> )
>>
>
>
>
> --
> Manu Suryavansh
>

Re: akka error : play framework (2.3.3) and spark (1.0.2)

Posted by Manu Suryavansh <su...@gmail.com>.
Hi,

I tried the Spark(1.0.0)+Play(2.3.3) example from the Knoldus blog -
http://blog.knoldus.com/2014/06/18/play-with-spark-building-apache-spark-with-play-framework/
and
it worked for me. The project is here -
https://github.com/knoldus/Play-Spark-Scala

Regards,
Manu


On Sat, Aug 16, 2014 at 11:04 PM, Sujee Maniyam <su...@sujee.net> wrote:

> Hi
>
> I am trying to connect to Spark from Play framework. Getting the following
> Akka error...
>
> [ERROR] [08/16/2014 17:12:05.249] [spark-akka.actor.default-dispatcher-3] [ActorSystem(spark)] Uncaught fatal error from thread [spark-akka.actor.default-dispatcher-3] shutting down ActorSystem [spark]
>
> java.lang.AbstractMethodError
>   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)
>   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)
>
>
> full stack trace : https://gist.github.com/sujee/ff14fd602b76314e693d
>
> source code here : https://github.com/sujee/play-spark-test
>
> I have also found this thread mentioning Akka in-compatibility How to run
> Play 2.2.x with Akka 2.3.x?
> <http://stackoverflow.com/questions/22779882/how-to-run-play-2-2-x-with-akka-2-3-x>
>
> Stack overflow thread :
> http://stackoverflow.com/questions/25346657/akka-error-play-framework-2-3-3-and-spark-1-0-2
>
> any suggestions?
>
> thanks!
>
> Sujee Maniyam (http://sujee.net | http://www.linkedin.com/in/sujeemaniyam
> )
>



-- 
Manu Suryavansh

Re: akka error : play framework (2.3.3) and spark (1.0.2)

Posted by Manu Suryavansh <su...@gmail.com>.
Hi,

I tried the Spark(1.0.0)+Play(2.3.3) example from the Knoldus blog -
http://blog.knoldus.com/2014/06/18/play-with-spark-building-apache-spark-with-play-framework/
and
it worked for me. The project is here -
https://github.com/knoldus/Play-Spark-Scala

Regards,
Manu


On Sat, Aug 16, 2014 at 11:04 PM, Sujee Maniyam <su...@sujee.net> wrote:

> Hi
>
> I am trying to connect to Spark from Play framework. Getting the following
> Akka error...
>
> [ERROR] [08/16/2014 17:12:05.249] [spark-akka.actor.default-dispatcher-3] [ActorSystem(spark)] Uncaught fatal error from thread [spark-akka.actor.default-dispatcher-3] shutting down ActorSystem [spark]
>
> java.lang.AbstractMethodError
>   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)
>   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)
>
>
> full stack trace : https://gist.github.com/sujee/ff14fd602b76314e693d
>
> source code here : https://github.com/sujee/play-spark-test
>
> I have also found this thread mentioning Akka in-compatibility How to run
> Play 2.2.x with Akka 2.3.x?
> <http://stackoverflow.com/questions/22779882/how-to-run-play-2-2-x-with-akka-2-3-x>
>
> Stack overflow thread :
> http://stackoverflow.com/questions/25346657/akka-error-play-framework-2-3-3-and-spark-1-0-2
>
> any suggestions?
>
> thanks!
>
> Sujee Maniyam (http://sujee.net | http://www.linkedin.com/in/sujeemaniyam
> )
>



-- 
Manu Suryavansh