diff options
| -rw-r--r-- | core/src/main/scala/spark/Executor.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/Executor.scala b/core/src/main/scala/spark/Executor.scala index b27a1ebd72..e534f48879 100644 --- a/core/src/main/scala/spark/Executor.scala +++ b/core/src/main/scala/spark/Executor.scala @@ -35,7 +35,7 @@ class Executor extends mesos.Executor with Logging { // Start worker thread pool threadPool = new ThreadPoolExecutor( - 1, 128, 600, TimeUnit.SECONDS, new LinkedBlockingQueue[Runnable]) + 1, 128, 600, TimeUnit.SECONDS, new SynchronousQueue[Runnable]) } override def launchTask(d: ExecutorDriver, desc: TaskDescription) { |