File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
core/src/test/scala/org/apache/spark/util Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -266,16 +266,16 @@ private object TestUserClosuresActuallyCleaned {
266266 rdd.mapPartitionsWithIndex { (_, it) => return ; it }.count()
267267 }
268268 def testFlatMapWith (rdd : RDD [Int ]): Unit = {
269- rdd.flatMapWith { (_, it) => return ; it }.count()
269+ rdd.flatMapWith { (it) => return ; it }.count()
270270 }
271271 def testMapWith (rdd : RDD [Int ]): Unit = {
272- rdd.mapWith { (_, it) => return ; it }.count()
272+ rdd.mapWith { (it) => return ; it }.count()
273273 }
274274 def testFilterWith (rdd : RDD [Int ]): Unit = {
275- rdd.filterWith { (_, it) => return ; it }.count()
275+ rdd.filterWith { (it) => return ; it }.count()
276276 }
277277 def testForEachWith (rdd : RDD [Int ]): Unit = {
278- rdd.foreachWith { (_, it) => return ; it }.count()
278+ rdd.foreachWith { (it) => return ; it }.count()
279279 }
280280 def testMapPartitionsWithContext (rdd : RDD [Int ]): Unit = {
281281 rdd.mapPartitionsWithContext { (_, it) => return ; it }.count()
You can’t perform that action at this time.
0 commit comments