diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-29 19:17:01 -0800 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-29 19:17:01 -0800 |
| commit | c62f2fefa50cc18d4e42d88205618089f9b225d3 (patch) | |
| tree | 766ff26fa024c4f6e7bd45b1366667c2e04a9043 | |
| parent | 15f1f6865d51a62c51098cb1ff93161fa725837c (diff) | |
| download | spark-c62f2fefa50cc18d4e42d88205618089f9b225d3.tar.gz spark-c62f2fefa50cc18d4e42d88205618089f9b225d3.tar.bz2 spark-c62f2fefa50cc18d4e42d88205618089f9b225d3.zip | |
Made LocalFileShuffle to be the default.
| -rw-r--r-- | src/scala/spark/RDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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) } |