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
