From c62f2fefa50cc18d4e42d88205618089f9b225d3 Mon Sep 17 00:00:00 2001 From: Mosharaf Chowdhury Date: Mon, 29 Nov 2010 19:17:01 -0800 Subject: [PATCH] Made LocalFileShuffle to be the default. --- src/scala/spark/RDD.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/scala/spark/RDD.scala b/src/scala/spark/RDD.scala index bac59319a0..39f2dc4458 100644 --- a/src/scala/spark/RDD.scala +++ b/src/scala/spark/RDD.scala @@ -359,7 +359,7 @@ extends RDD[Pair[T, U]](sc) { : RDD[(K, C)] = { val shufClass = Class.forName(System.getProperty( - "spark.shuffle.class", "spark.DfsShuffle")) + "spark.shuffle.class", "spark.LocalFileShuffle")) val shuf = shufClass.newInstance().asInstanceOf[Shuffle[K, V, C]] shuf.compute(self, numSplits, createCombiner, mergeValue, mergeCombiners) }