From 11f2795ef4e592a6e80264c7a45db9ad8999b17d Mon Sep 17 00:00:00 2001 From: Andy Grove Date: Sat, 27 Apr 2024 09:06:42 -0600 Subject: [PATCH] revert a change --- .../main/scala/org/apache/comet/serde/QueryPlanSerde.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala index 78175933f..169c17100 100644 --- a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala +++ b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala @@ -575,7 +575,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde { val value = cast.eval() exprToProtoInternal(Literal(value, dataType), inputs) - case cast @ Cast(child, dt, timeZoneId, evalMode) => + case Cast(child, dt, timeZoneId, evalMode) => val childExpr = exprToProtoInternal(child, inputs) if (childExpr.isDefined) { val evalModeStr = if (evalMode.isInstanceOf[Boolean]) { @@ -589,7 +589,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde { case (DataTypes.StringType, DataTypes.TimestampType) if !CometConf.COMET_CAST_STRING_TO_TIMESTAMP.get() => // https://github.com/apache/datafusion-comet/issues/328 - withInfo(cast, s"${CometConf.COMET_CAST_STRING_TO_TIMESTAMP.key} is disabled") + withInfo(expr, s"${CometConf.COMET_CAST_STRING_TO_TIMESTAMP.key} is disabled") false case _ => true }