Made LocalFileShuffle to be the default.

This commit is contained in:
Mosharaf Chowdhury 2010-11-29 19:19:21 -08:00
parent bb3e7fbf61
commit 73714da568

View file

@ -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)
}