Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/19962#discussion_r156658661
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala
---
@@ -1065,7 +1031,7 @@ case class ScalaUDF(
""".stripMargin)
}
- private[this] val converter =
CatalystTypeConverters.createToCatalystConverter(dataType)
+ private[this] val resultConverter =
CatalystTypeConverters.createToCatalystConverter(dataType)
lazy val udfErrorMessage = {
--- End diff --
Ok. makes sense.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
