From 1323fe69036c0eb0163de11fbdbb9b30e6391892 Mon Sep 17 00:00:00 2001 From: tedyu Date: Sat, 23 Apr 2016 07:12:20 -0700 Subject: [PATCH] [SPARK-14856] Correct message in assertion for 'returning batch for wide table' --- .../sql/execution/datasources/parquet/ParquetQuerySuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetQuerySuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetQuerySuite.scala index ed20c45d5f93f..f1e9726c38b02 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetQuerySuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetQuerySuite.scala @@ -609,7 +609,7 @@ class ParquetQuerySuite extends QueryTest with ParquetTest with SharedSQLContext val df3 = df2.selectExpr(columns : _*) assert( df3.queryExecution.sparkPlan.find(_.isInstanceOf[BatchedDataSourceScanExec]).isDefined, - "Should not return batch") + "Should return batch") checkAnswer(df3, df.selectExpr(columns : _*)) } }