spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From wenc...@apache.org
Subject spark git commit: [SPARK-14554][SQL][FOLLOW-UP] use checkDataset to check the result
Date Wed, 13 Apr 2016 03:41:20 GMT
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 <wenchen@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 <wenchen@databricks.com>
Authored: Wed Apr 13 11:41:09 2016 +0800
Committer: Wenchen Fan <wenchen@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message