Skip to content

Commit c0f85bb

Browse files
author
Davies Liu
committed
fix passing null into ScalaUDF
1 parent b1b4ee7 commit c0f85bb

File tree

1 file changed

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

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1032,8 +1032,8 @@ case class ScalaUDF(
10321032
val funcArguments = converterTerms.zipWithIndex.map {
10331033
case (converter, i) =>
10341034
val eval = evals(i)
1035-
val dt = children(i).dataType
1036-
s"$converter.apply(${eval.isNull} ? null : (${ctx.boxedType(dt)}) ${eval.value})"
1035+
val boxedType = ctx.boxedType(children(i).dataType)
1036+
s"$converter.apply(${eval.isNull} ? ($boxedType) null : ($boxedType) ${eval.value})"
10371037
}.mkString(",")
10381038
val callFunc = s"${ctx.boxedType(ctx.javaType(dataType))} $resultTerm = " +
10391039
s"(${ctx.boxedType(ctx.javaType(dataType))})${catalystConverterTerm}" +

0 commit comments

Comments
 (0)