aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2013-07-22 16:05:32 -0700
committerMatei Zaharia <matei@eecs.berkeley.edu>2013-07-22 16:05:32 -0700
commit8e38e7723230c1ca9564ddb79087fd1c4326b351 (patch)
tree2db215fe7f6bff1c7d4119867651df1c9a285d42
parent15fb3948330721aba4716fa80c75e9bafab1a1b6 (diff)
downloadspark-8e38e7723230c1ca9564ddb79087fd1c4326b351.tar.gz
spark-8e38e7723230c1ca9564ddb79087fd1c4326b351.tar.bz2
spark-8e38e7723230c1ca9564ddb79087fd1c4326b351.zip
Fix a test that was using an outdated config setting
-rw-r--r--core/src/test/scala/spark/ShuffleSuite.scala6
1 files changed, 3 insertions, 3 deletions
diff --git a/core/src/test/scala/spark/ShuffleSuite.scala b/core/src/test/scala/spark/ShuffleSuite.scala
index 3a56c26bef..752e4b85e6 100644
--- a/core/src/test/scala/spark/ShuffleSuite.scala
+++ b/core/src/test/scala/spark/ShuffleSuite.scala
@@ -33,9 +33,9 @@ import spark.rdd.ShuffledRDD
import spark.SparkContext._
class ShuffleSuite extends FunSuite with ShouldMatchers with LocalSparkContext {
- test("groupByKey with compression") {
+ test("groupByKey without compression") {
try {
- System.setProperty("spark.shuffle.compress", "true")
+ System.setProperty("spark.shuffle.compress", "false")
sc = new SparkContext("local", "test")
val pairs = sc.parallelize(Array((1, 1), (1, 2), (1, 3), (2, 1)), 4)
val groups = pairs.groupByKey(4).collect()
@@ -45,7 +45,7 @@ class ShuffleSuite extends FunSuite with ShouldMatchers with LocalSparkContext {
val valuesFor2 = groups.find(_._1 == 2).get._2
assert(valuesFor2.toList.sorted === List(1))
} finally {
- System.setProperty("spark.blockManager.compress", "false")
+ System.setProperty("spark.shuffle.compress", "true")
}
}