This is an automated email from the ASF dual-hosted git repository. hvanhovell pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/spark.git
commit 2c465f681ada8be8cb53edfff3ddbd273b89bc72 Author: Herman van Hovell <her...@databricks.com> AuthorDate: Mon Aug 14 04:59:59 2023 +0200 Add test --- .../scala/org/apache/spark/sql/application/ReplE2ESuite.scala | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/application/ReplE2ESuite.scala b/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/application/ReplE2ESuite.scala index 0e69b5afa45..0cab66eef3d 100644 --- a/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/application/ReplE2ESuite.scala +++ b/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/application/ReplE2ESuite.scala @@ -276,4 +276,13 @@ class ReplE2ESuite extends RemoteSparkSession with BeforeAndAfterEach { val output = runCommandsInShell(input) assertContains("Array[MyTestClass] = Array(MyTestClass(1), MyTestClass(3))", output) } + + test("REPL class in UDF") { + val input = """ + |case class MyTestClass(value: Int) + |spark.range(2).map(i => MyTestClass(i.toInt)).collect() + """.stripMargin + val output = runCommandsInShell(input) + assertContains("Array[MyTestClass] = Array(MyTestClass(0), MyTestClass(1))", output) + } } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org