Skip to content

Commit e6bb55d

Browse files
committed
fix
1 parent 3e97fa5 commit e6bb55d

File tree

1 file changed

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

1 file changed

+6
-3
lines changed

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

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1101,10 +1101,13 @@ case class ScalaUDF(
11011101
|Object $argTerm = ${eval.isNull} ? null : $convertedTerm;
11021102
""".stripMargin
11031103
} else if (useEncoders(i)) {
1104-
val convInput = ctx.freshName("convInput")
11051104
s"""
1106-
|Object $convInput = ${eval.isNull} ? null : (Object) ${eval.value};
1107-
|Object $argTerm = $convertersTerm[$i].apply($convInput);
1105+
|Object $argTerm = null;
1106+
|if (${eval.isNull}) {
1107+
| $argTerm = $convertersTerm[$i].apply(null);
1108+
|} else {
1109+
| $argTerm = $convertersTerm[$i].apply(${eval.value});
1110+
|}
11081111
""".stripMargin
11091112
} else {
11101113
s"Object $argTerm = ${eval.isNull} ? null : $convertersTerm[$i].apply(${eval.value});"

0 commit comments

Comments
 (0)