Skip to content

Commit adf3292

Browse files
committed
prep for review
1 parent 860fc93 commit adf3292

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -552,6 +552,7 @@ object QueryPlanSerde extends Logging with CometExprShim {
552552
dt: DataType,
553553
timeZoneId: Option[String],
554554
evalMode: CometEvalMode.Value): Option[Expr] = {
555+
555556
val childExpr = exprToProtoInternal(child, inputs, binding)
556557
if (childExpr.isDefined) {
557558
val castSupport =
@@ -678,7 +679,7 @@ object QueryPlanSerde extends Logging with CometExprShim {
678679
CometEvalMode.TRY)
679680

680681
case c @ Cast(child, dt, timeZoneId, _) =>
681-
handleCast(c, child, inputs, binding, dt, timeZoneId, evalMode(c))
682+
handleCast(expr, child, inputs, binding, dt, timeZoneId, evalMode(c))
682683

683684
case EqualTo(left, right) =>
684685
createBinaryExpr(

0 commit comments

Comments
 (0)