Skip to content

Commit 3771474

Browse files
committed
fix RDDSuite
1 parent 996d6f9 commit 3771474

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -268,8 +268,9 @@ class RDDSuite extends FunSuite with SharedSparkContext {
268268

269269
// we can optionally shuffle to keep the upstream parallel
270270
val coalesced5 = data.coalesce(1, shuffle = true)
271-
assert(coalesced5.dependencies.head.rdd.dependencies.head.rdd.
272-
asInstanceOf[ShuffledRDD[Int, Int, (Int, Int)]] !== null )
271+
val isEquals = coalesced5.dependencies.head.rdd.dependencies.head.rdd.
272+
asInstanceOf[ShuffledRDD[_, _, _]] != null
273+
assert(isEquals)
273274

274275
// when shuffling, we can increase the number of partitions
275276
val coalesced6 = data.coalesce(20, shuffle = true)

0 commit comments

Comments
 (0)