diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-07-22 16:05:32 -0700 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-07-22 16:05:32 -0700 |
commit | 8e38e7723230c1ca9564ddb79087fd1c4326b351 (patch) | |
tree | 2db215fe7f6bff1c7d4119867651df1c9a285d42 | |
parent | 15fb3948330721aba4716fa80c75e9bafab1a1b6 (diff) | |
download | spark-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.scala | 6 |
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") } } |