Skip to content

Commit 55406de

Browse files
committed
[HOTFIX] Remove cleaning of UDFs
1 parent f38fab9 commit 55406de

File tree

1 file changed

+0
-3
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions

1 file changed

+0
-3
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUdf.scala

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,6 @@ import org.apache.spark.util.ClosureCleaner
2323
case class ScalaUdf(function: AnyRef, dataType: DataType, children: Seq[Expression])
2424
extends Expression {
2525

26-
// Clean function when not called with default no-arg constructor.
27-
if (function != null) { ClosureCleaner.clean(function) }
28-
2926
type EvaluatedType = Any
3027

3128
def nullable = true

0 commit comments

Comments
 (0)