You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by va...@apache.org on 2016/04/07 03:30:48 UTC
spark git commit: [SPARK-14446][TESTS] Fix ReplSuite for Scala 2.10.
Repository: spark
Updated Branches:
refs/heads/master 611dbce4b -> 4901086fe
[SPARK-14446][TESTS] Fix ReplSuite for Scala 2.10.
Just use the same test code as the 2.11 version, which seems to pass.
Author: Marcelo Vanzin <va...@cloudera.com>
Closes #12223 from vanzin/SPARK-14446.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/4901086f
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/4901086f
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/4901086f
Branch: refs/heads/master
Commit: 4901086fea969a34ec312ef4a8f83d84e1bf21fb
Parents: 611dbce
Author: Marcelo Vanzin <va...@cloudera.com>
Authored: Wed Apr 6 18:30:41 2016 -0700
Committer: Marcelo Vanzin <va...@cloudera.com>
Committed: Wed Apr 6 18:30:41 2016 -0700
----------------------------------------------------------------------
.../src/test/scala/org/apache/spark/repl/ReplSuite.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/4901086f/repl/scala-2.10/src/test/scala/org/apache/spark/repl/ReplSuite.scala
----------------------------------------------------------------------
diff --git a/repl/scala-2.10/src/test/scala/org/apache/spark/repl/ReplSuite.scala b/repl/scala-2.10/src/test/scala/org/apache/spark/repl/ReplSuite.scala
index 6b9aa50..c8b78bc 100644
--- a/repl/scala-2.10/src/test/scala/org/apache/spark/repl/ReplSuite.scala
+++ b/repl/scala-2.10/src/test/scala/org/apache/spark/repl/ReplSuite.scala
@@ -357,7 +357,7 @@ class ReplSuite extends SparkFunSuite {
|
|def sum[I, N : Numeric : Encoder](f: I => N): TypedColumn[I, N] = new SumOf(f).toColumn
|val ds = Seq((1, 1, 2L), (1, 2, 3L), (1, 3, 4L), (2, 1, 5L)).toDS()
- |ds.groupBy(_._1).agg(sum(_._2), sum(_._3)).collect()
+ |ds.groupByKey(_._1).agg(sum(_._2), sum(_._3)).collect()
""".stripMargin)
assertDoesNotContain("error:", output)
assertDoesNotContain("Exception", output)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org