[ 
https://issues.apache.org/jira/browse/SPARK-689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Andrew Ash closed SPARK-689.
----------------------------
    Resolution: Cannot Reproduce

> Task will crash when setting SPARK_WORKER_CORES> 128
> ----------------------------------------------------
>
>                 Key: SPARK-689
>                 URL: https://issues.apache.org/jira/browse/SPARK-689
>             Project: Spark
>          Issue Type: Bug
>          Components: Spark Core
>    Affects Versions: 0.6.1
>            Reporter: xiajunluan
>
> when I set SPARK_WORKER_CORES > 128(for example 200), and run a job in 
> standalone mode that will allocate 200 tasks in one worker node, then task 
> will crash(it seems that worker cores has been hard-code)
> {noformat}
> 13/02/07 11:25:02 ERROR StandaloneExecutorBackend: Task 
> spark.executor.Executor$TaskRunner@5367839e rejected from 
> java.util.concurrent.ThreadPoolExecutor@30f224d9[Running, pool size = 128, 
> active threads = 128, queued tasks = 0, completed tasks = 0]
> java.util.concurrent.RejectedExecutionException: Task 
> spark.executor.Executor$TaskRunner@5367839e rejected from 
> java.util.concurrent.ThreadPoolExecutor@30f224d9[Running, pool size = 128, 
> active threads = 128, queued tasks = 0, completed tasks = 0]
>       at 
> java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2013)
>       at 
> java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:816)
>       at 
> java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1337)
>       at spark.executor.Executor.launchTask(Executor.scala:59)
>       at 
> spark.executor.StandaloneExecutorBackend$$anonfun$receive$1.apply(StandaloneExecutorBackend.scala:57)
>       at 
> spark.executor.StandaloneExecutorBackend$$anonfun$receive$1.apply(StandaloneExecutorBackend.scala:46)
>       at akka.actor.Actor$class.apply(Actor.scala:318)
>       at 
> spark.executor.StandaloneExecutorBackend.apply(StandaloneExecutorBackend.scala:17)
>       at akka.actor.ActorCell.invoke(ActorCell.scala:626)
>       at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:197)
>       at akka.dispatch.Mailbox.run(Mailbox.scala:179)
>       at 
> akka.dispatch.ForkJoinExecutorConfigurator$MailboxExecutionTask.exec(AbstractDispatcher.scala:516)
>       at akka.jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:259)
>       at akka.jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:975)
>       at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479)
>       at akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
> 13/02/07 11:25:02 INFO StandaloneExecutorBackend: Connecting to master: 
> akka://spark@10.0.2.19:60882/user/StandaloneScheduler
> 13/02/07 11:25:02 INFO StandaloneExecutorBackend: Got assigned task 1929
> 13/02/07 11:25:02 INFO Executor: launch taskId: 1929
> 13/02/07 11:25:02 ERROR StandaloneExecutorBackend: 
> java.lang.NullPointerException
>       at spark.executor.Executor.launchTask(Executor.scala:59)
>       at 
> spark.executor.StandaloneExecutorBackend$$anonfun$receive$1.apply(StandaloneExecutorBackend.scala:57)
>       at 
> spark.executor.StandaloneExecutorBackend$$anonfun$receive$1.apply(StandaloneExecutorBackend.scala:46)
>       at akka.actor.Actor$class.apply(Actor.scala:318)
>       at 
> spark.executor.StandaloneExecutorBackend.apply(StandaloneExecutorBackend.scala:17)
>       at akka.actor.ActorCell.invoke(ActorCell.scala:626)
>       at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:197)
>       at akka.dispatch.Mailbox.run(Mailbox.scala:179)
>       at 
> akka.dispatch.ForkJoinExecutorConfigurator$MailboxExecutionTask.exec(AbstractDispatcher.scala:516)
>       at akka.jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:259)
>       at akka.jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:975)
>       at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479)
>       at akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
> 13/02/07 11:25:02 INFO StandaloneExecutorBackend: Connecting to master: 
> akka://spark@10.0.2.19:60882/user/StandaloneScheduler
> 13/02/07 11:25:02 INFO StandaloneExecutorBackend: Got assigned task 1930
> 13/02/07 11:25:02 INFO Executor: launch taskId: 1930
> 13/02/07 11:25:02 ERROR StandaloneExecutorBackend: 
> java.lang.NullPointerException
>       at spark.executor.Executor.launchTask(Executor.scala:59)
>       at 
> spark.executor.StandaloneExecutorBackend$$anonfun$receive$1.apply(StandaloneExecutorBackend.scala:57)
>       at 
> spark.executor.StandaloneExecutorBackend$$anonfun$receive$1.apply(StandaloneExecutorBackend.scala:46)
>       at akka.actor.Actor$class.apply(Actor.scala:318)
>       at 
> spark.executor.StandaloneExecutorBackend.apply(StandaloneExecutorBackend.scala:17)
>       at akka.actor.ActorCell.invoke(ActorCell.scala:626)
>       at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:197)
>       at akka.dispatch.Mailbox.run(Mailbox.scala:179)
>       at 
> akka.dispatch.ForkJoinExecutorConfigurator$MailboxExecutionTask.exec(AbstractDispatcher.scala:516)
>       at akka.jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:259)
>       at akka.jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:975)
>       at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479)
>       at akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
> {noformat}



--
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

Reply via email to