diff options
| author | Ernest <earneyzxl@gmail.com> | 2014-12-18 15:42:26 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2014-12-18 15:42:26 -0800 |
| commit | a7ed6f3cc537f57de87d28e8466ca88fbfff53b5 (patch) | |
| tree | 98149170d3dc2e626ae001f48a6fa3e65b6894f3 /examples/src | |
| parent | 59a49db5982ecc487187fcd92399e08b4b4bea64 (diff) | |
| download | spark-a7ed6f3cc537f57de87d28e8466ca88fbfff53b5.tar.gz spark-a7ed6f3cc537f57de87d28e8466ca88fbfff53b5.tar.bz2 spark-a7ed6f3cc537f57de87d28e8466ca88fbfff53b5.zip | |
[SPARK-4880] remove spark.locality.wait in Analytics
spark.locality.wait set to 100000 in examples/graphx/Analytics.scala.
Should be left to the user.
Author: Ernest <earneyzxl@gmail.com>
Closes #3730 from Earne/SPARK-4880 and squashes the following commits:
d79ed04 [Ernest] remove spark.locality.wait in Analytics
Diffstat (limited to 'examples/src')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/graphx/Analytics.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/graphx/Analytics.scala b/examples/src/main/scala/org/apache/spark/examples/graphx/Analytics.scala index 828cffb01c..9cc47327f9 100644 --- a/examples/src/main/scala/org/apache/spark/examples/graphx/Analytics.scala +++ b/examples/src/main/scala/org/apache/spark/examples/graphx/Analytics.scala @@ -46,7 +46,7 @@ object Analytics extends Logging { } val options = mutable.Map(optionsList: _*) - val conf = new SparkConf().set("spark.locality.wait", "100000") + val conf = new SparkConf() GraphXUtils.registerKryoClasses(conf) val numEPart = options.remove("numEPart").map(_.toInt).getOrElse { |