From 7e7525995d383af03a8b4179e8f3139cd97e2e12 Mon Sep 17 00:00:00 2001 From: Josh Rosen Date: Sat, 18 Jul 2015 17:49:57 -0700 Subject: [PATCH] Fix cast in SparkSqlSerializer2Suite --- .../apache/spark/sql/execution/SparkSqlSerializer2Suite.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkSqlSerializer2Suite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkSqlSerializer2Suite.scala index 71f6b26bcd01a..4a53fadd7e099 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkSqlSerializer2Suite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkSqlSerializer2Suite.scala @@ -132,8 +132,8 @@ abstract class SparkSqlSerializer2Suite extends QueryTest with BeforeAndAfterAll expectedSerializerClass: Class[T]): Unit = { executedPlan.foreach { case exchange: Exchange => - val shuffledRDD = exchange.execute().firstParent.asInstanceOf[ShuffledRDD[_, _, _]] - val dependency = shuffledRDD.getDependencies.head.asInstanceOf[ShuffleDependency[_, _, _]] + val shuffledRDD = exchange.execute() + val dependency = shuffledRDD.dependencies.head.asInstanceOf[ShuffleDependency[_, _, _]] val serializerNotSetMessage = s"Expected $expectedSerializerClass as the serializer of Exchange. " + s"However, the serializer was not set."