From 4c888b2933cd8e3695378b5a3c09adf97ab5f827 Mon Sep 17 00:00:00 2001
From: Matei Zaharia <matei@eecs.berkeley.edu>
Date: Sun, 22 May 2011 16:42:05 -0700
Subject: [PATCH] Fix queue type for executor
---
core/src/main/scala/spark/Executor.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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) {
--
GitLab