From f50b23b825dfbaa7ad65a8c27db2cc7eb0b2ebfa Mon Sep 17 00:00:00 2001
From: Matei Zaharia <matei@eecs.berkeley.edu>
Date: Wed, 29 Sep 2010 10:04:00 -0700
Subject: [PATCH] Increase default locality wait to 3s. Fixes #20.
---
src/scala/spark/MesosScheduler.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/scala/spark/MesosScheduler.scala b/src/scala/spark/MesosScheduler.scala
index 42ad45a56f..2face7f08d 100644
--- a/src/scala/spark/MesosScheduler.scala
+++ b/src/scala/spark/MesosScheduler.scala
@@ -208,7 +208,7 @@ class SimpleParallelOperation[T: ClassManifest](
extends ParallelOperation
{
// Maximum time to wait to run a task in a preferred location (in ms)
- val LOCALITY_WAIT = System.getProperty("spark.locality.wait", "1000").toLong
+ val LOCALITY_WAIT = System.getProperty("spark.locality.wait", "3000").toLong
val callingThread = currentThread
val numTasks = tasks.length
--
GitLab