From 046540d983f341b3f01c1369fce9572db4e00428 Mon Sep 17 00:00:00 2001 From: witgo Date: Fri, 9 May 2014 16:31:52 +0800 Subject: [PATCH] fix RDDSuite.scala --- core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala b/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala index bfd4e55cbcac1..5544a143291a4 100644 --- a/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala +++ b/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala @@ -235,9 +235,8 @@ class RDDSuite extends FunSuite with SharedSparkContext { // we can optionally shuffle to keep the upstream parallel val coalesced5 = data.coalesce(1, shuffle = true) - val bool = coalesced5.dependencies.head.rdd.dependencies.head.rdd.asInstanceOf[ShuffledRDD[_, _, _]] != - null - assert(bool) + assert(coalesced5.dependencies.head.rdd.dependencies.head.rdd. + asInstanceOf[ShuffledRDD[Int, Int, (Int, Int)]] !== null ) // when shuffling, we can increase the number of partitions val coalesced6 = data.coalesce(20, shuffle = true)