You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@spark.apache.org by "Arthur.hk.chan@gmail.com" <ar...@gmail.com> on 2014/09/11 15:41:31 UTC

unable to create new native thread

Hi 

I am trying the Spark sample program “SparkPi”, I got an error "unable to create new native thread", how to resolve this?

14/09/11 21:36:16 INFO scheduler.DAGScheduler: Completed ResultTask(0, 644)
14/09/11 21:36:16 INFO scheduler.TaskSetManager: Finished TID 643 in 43 ms on node1 (progress: 636/100000)
14/09/11 21:36:16 INFO scheduler.DAGScheduler: Completed ResultTask(0, 643)
14/09/11 21:36:16 ERROR actor.ActorSystemImpl: Uncaught fatal error from thread [spark-akka.actor.default-dispatcher-16] shutting down ActorSystem [spark]
java.lang.OutOfMemoryError: unable to create new native thread
	at java.lang.Thread.start0(Native Method)
	at java.lang.Thread.start(Thread.java:714)
	at scala.concurrent.forkjoin.ForkJoinPool.tryAddWorker(ForkJoinPool.java:1672)
	at scala.concurrent.forkjoin.ForkJoinPool.signalWork(ForkJoinPool.java:1966)
	at scala.concurrent.forkjoin.ForkJoinPool.externalPush(ForkJoinPool.java:1829)
	at scala.concurrent.forkjoin.ForkJoinPool.execute(ForkJoinPool.java:2955)
	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinPool.execute(AbstractDispatcher.scala:374)
	at akka.dispatch.ExecutorServiceDelegate$class.execute(ThreadPoolBuilder.scala:212)
	at akka.dispatch.Dispatcher$LazyExecutorServiceDelegate.execute(Dispatcher.scala:43)
	at akka.dispatch.Dispatcher.registerForExecution(Dispatcher.scala:118)
	at akka.dispatch.Dispatcher.dispatch(Dispatcher.scala:59)
	at akka.actor.dungeon.Dispatch$class.sendMessage(Dispatch.scala:120)
	at akka.actor.ActorCell.sendMessage(ActorCell.scala:338)
	at akka.actor.Cell$class.sendMessage(ActorCell.scala:259)
	at akka.actor.ActorCell.sendMessage(ActorCell.scala:338)
	at akka.actor.LocalActorRef.$bang(ActorRef.scala:389)
	at akka.actor.ActorRef.tell(ActorRef.scala:125)
	at akka.actor.ActorCell.autoReceiveMessage(ActorCell.scala:489)
	at akka.actor.ActorCell.invoke(ActorCell.scala:455)
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:237)
	at akka.dispatch.Mailbox.run(Mailbox.scala:219)
	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386)
	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)


Regards
Arthur