From bfbb4feede17c76bf74ef677c034ab4ad86a9f26 Mon Sep 17 00:00:00 2001 From: Imran Rashid Date: Mon, 4 Jan 2016 14:36:21 -0600 Subject: [PATCH] SQLTestUtils.stripSparkFilter must copy the row, as df.collect() would do --- .../src/test/scala/org/apache/spark/sql/test/SQLTestUtils.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/core/src/test/scala/org/apache/spark/sql/test/SQLTestUtils.scala b/sql/core/src/test/scala/org/apache/spark/sql/test/SQLTestUtils.scala index e87da1527c4d..1da604c785d1 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/test/SQLTestUtils.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/test/SQLTestUtils.scala @@ -189,7 +189,7 @@ private[sql] trait SQLTestUtils .executedPlan.asInstanceOf[org.apache.spark.sql.execution.Filter] .child .execute() - .map(row => Row.fromSeq(row.toSeq(schema))) + .map(row => Row.fromSeq(row.copy().toSeq(schema))) sqlContext.createDataFrame(childRDD, schema) }