diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2014-01-18 11:55:10 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-01-18 11:58:42 -0800 |
| commit | 5316bcac3c8fb14fdff637c8c147c22b373397f4 (patch) | |
| tree | 929f3fde11e0f6cbc4aae7ca582ab02181199e43 | |
| parent | d749d472b37448edb322bc7208a3db925c9a4fc2 (diff) | |
| download | spark-5316bcac3c8fb14fdff637c8c147c22b373397f4.tar.gz spark-5316bcac3c8fb14fdff637c8c147c22b373397f4.tar.bz2 spark-5316bcac3c8fb14fdff637c8c147c22b373397f4.zip | |
Use renamed shuffle spill config in CoGroupedRDD.scala
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala b/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala index f2feb406f7..0e47f2e022 100644 --- a/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala @@ -106,7 +106,7 @@ class CoGroupedRDD[K](@transient var rdds: Seq[RDD[_ <: Product2[K, _]]], part: override def compute(s: Partition, context: TaskContext): Iterator[(K, CoGroupCombiner)] = { val sparkConf = SparkEnv.get.conf - val externalSorting = sparkConf.getBoolean("spark.shuffle.externalSorting", true) + val externalSorting = sparkConf.getBoolean("spark.shuffle.spill", true) val split = s.asInstanceOf[CoGroupPartition] val numRdds = split.deps.size |