Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/19454#discussion_r143608933
--- Diff: core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala ---
@@ -63,6 +63,7 @@ class RDDSuite extends SparkFunSuite with
SharedSparkContext {
assert(nums.map(_.toString).collect().toList === List("1", "2", "3",
"4"))
assert(nums.filter(_ > 2).collect().toList === List(3, 4))
assert(nums.flatMap(x => 1 to x).collect().toList === List(1, 1, 2, 1,
2, 3, 1, 2, 3, 4))
+ assert(sc.makeRDD(Array(Array(1,2,3,4), Array(1,2,3,4))).flatten ==
List(1,2,3,4,1,2,3,4))
--- End diff --
`.flatten.collect().toList`.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
