From 2a928b2b2efae1da5744fad7f49f7979f5bf72b7 Mon Sep 17 00:00:00 2001 From: Ankur Dave Date: Fri, 25 Apr 2014 03:08:27 -0700 Subject: [PATCH] Set locality wait --- .../src/main/scala/org/apache/spark/graphx/lib/Analytics.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/graphx/src/main/scala/org/apache/spark/graphx/lib/Analytics.scala b/graphx/src/main/scala/org/apache/spark/graphx/lib/Analytics.scala index 4a3c3344daf83..3c14e0fbe3eac 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/lib/Analytics.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/lib/Analytics.scala @@ -51,6 +51,7 @@ object Analytics extends Logging { val conf = new SparkConf() .set("spark.serializer", "org.apache.spark.serializer.KryoSerializer") .set("spark.kryo.registrator", "org.apache.spark.graphx.GraphKryoRegistrator") + .set("spark.locality.wait", "100000") taskType match { case "pagerank" =>