From 174a6f951be41fad728496fab9bfd5f600e48d87 Mon Sep 17 00:00:00 2001 From: "yi.wu" Date: Fri, 17 Dec 2021 21:43:33 +0800 Subject: [PATCH] fix --- .../org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala index 8ab18cc647002..832b2656f0c96 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala @@ -67,7 +67,7 @@ case class ScalaUDF( override lazy val preCanonicalized: Expression = { // SPARK-32307: `ExpressionEncoder` can't be canonicalized, and technically we don't // need it to identify a `ScalaUDF`. - copy(children = children.map(_.preCanonicalized), inputEncoders = Nil) + copy(children = children.map(_.preCanonicalized), inputEncoders = Nil, outputEncoder = None) } /**