diff options
| author | Stephen Haberman <stephen@exigencecorp.com> | 2013-03-14 14:44:15 -0500 |
|---|---|---|
| committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-03-14 14:44:15 -0500 |
| commit | 7d8bb4df3a5f8078cd4e86cef5e3b0b728afd2bc (patch) | |
| tree | 0e30865dcec15ba4a8a4da83ad23825b43b3b6f8 /core/src/test | |
| parent | 4632c45af16dbdbf9e959fb9cac7f5f4a8d44357 (diff) | |
| download | spark-7d8bb4df3a5f8078cd4e86cef5e3b0b728afd2bc.tar.gz spark-7d8bb4df3a5f8078cd4e86cef5e3b0b728afd2bc.tar.bz2 spark-7d8bb4df3a5f8078cd4e86cef5e3b0b728afd2bc.zip | |
Allow subtractByKey's other argument to have a different value type.
Diffstat (limited to 'core/src/test')
| -rw-r--r-- | core/src/test/scala/spark/ShuffleSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/test/scala/spark/ShuffleSuite.scala b/core/src/test/scala/spark/ShuffleSuite.scala index 731c45cca2..2b2a90defa 100644 --- a/core/src/test/scala/spark/ShuffleSuite.scala +++ b/core/src/test/scala/spark/ShuffleSuite.scala @@ -283,7 +283,7 @@ class ShuffleSuite extends FunSuite with ShouldMatchers with LocalSparkContext { test("subtractByKey") { sc = new SparkContext("local", "test") val a = sc.parallelize(Array((1, "a"), (1, "a"), (2, "b"), (3, "c")), 2) - val b = sc.parallelize(Array((2, "bb"), (3, "cc"), (4, "dd")), 4) + val b = sc.parallelize(Array((2, 20), (3, 30), (4, 40)), 4) val c = a.subtractByKey(b) assert(c.collect().toSet === Set((1, "a"), (1, "a"))) assert(c.partitions.size === a.partitions.size) |