diff options
| author | Marcelo Vanzin <vanzin@cloudera.com> | 2016-04-06 18:30:41 -0700 |
|---|---|---|
| committer | Marcelo Vanzin <vanzin@cloudera.com> | 2016-04-06 18:30:41 -0700 |
| commit | 4901086fea969a34ec312ef4a8f83d84e1bf21fb (patch) | |
| tree | 9c1e9a6fb979bdb7817313f50576d7494ab24d69 | |
| parent | 611dbce4bdd6f34ac1fa67d8dfa3d407600a0237 (diff) | |
| download | spark-4901086fea969a34ec312ef4a8f83d84e1bf21fb.tar.gz spark-4901086fea969a34ec312ef4a8f83d84e1bf21fb.tar.bz2 spark-4901086fea969a34ec312ef4a8f83d84e1bf21fb.zip | |
[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 <vanzin@cloudera.com>
Closes #12223 from vanzin/SPARK-14446.
| -rw-r--r-- | repl/scala-2.10/src/test/scala/org/apache/spark/repl/ReplSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 6b9aa5071e..c8b78bc14a 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) |