Repository: spark Updated Branches: refs/heads/master 587cd554a -> a5f8c9b15
[SPARK-14554][SQL][FOLLOW-UP] use checkDataset to check the result ## What changes were proposed in this pull request? address this comment: https://github.com/apache/spark/pull/12322#discussion_r59417359 ## How was this patch tested? N/A Author: Wenchen Fan <wenc...@databricks.com> Closes #12346 from cloud-fan/tmp. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/a5f8c9b1 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/a5f8c9b1 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/a5f8c9b1 Branch: refs/heads/master Commit: a5f8c9b15b6181f04c1314c638017adb8c88c7df Parents: 587cd55 Author: Wenchen Fan <wenc...@databricks.com> Authored: Wed Apr 13 11:41:09 2016 +0800 Committer: Wenchen Fan <wenc...@databricks.com> Committed: Wed Apr 13 11:41:09 2016 +0800 ---------------------------------------------------------------------- sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/a5f8c9b1/sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala ---------------------------------------------------------------------- diff --git a/sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala index 4725168..d074535 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala @@ -624,7 +624,7 @@ class DatasetSuite extends QueryTest with SharedSQLContext { test("SPARK-14554: Dataset.map may generate wrong java code for wide table") { val wideDF = sqlContext.range(10).select(Seq.tabulate(1000) {i => ('id + i).as(s"c$i")} : _*) // Make sure the generated code for this plan can compile and execute. - wideDF.map(_.getLong(0)).collect() + checkDataset(wideDF.map(_.getLong(0)), 0L until 10 : _*) } } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
