diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-29 19:19:21 -0800 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-29 19:19:21 -0800 |
| commit | 73714da568f172af073f003740700e2bee07837b (patch) | |
| tree | 0ca41267ddaf836eb2e9a577e2e69cb7bad12a94 | |
| parent | bb3e7fbf61ed26a107e43f0addfa718125a754f6 (diff) | |
| download | spark-73714da568f172af073f003740700e2bee07837b.tar.gz spark-73714da568f172af073f003740700e2bee07837b.tar.bz2 spark-73714da568f172af073f003740700e2bee07837b.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) } |