Skip to content

Commit 046540d

Browse files
committed
fix RDDSuite.scala
1 parent 2c543b9 commit 046540d

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

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

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

236236
// we can optionally shuffle to keep the upstream parallel
237237
val coalesced5 = data.coalesce(1, shuffle = true)
238-
val bool = coalesced5.dependencies.head.rdd.dependencies.head.rdd.asInstanceOf[ShuffledRDD[_, _, _]] !=
239-
null
240-
assert(bool)
238+
assert(coalesced5.dependencies.head.rdd.dependencies.head.rdd.
239+
asInstanceOf[ShuffledRDD[Int, Int, (Int, Int)]] !== null )
241240

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

0 commit comments

Comments
 (0)