From 2cd5f5fa40f6cf726dc89dc202c065b7166231d1 Mon Sep 17 00:00:00 2001 From: Andy Grove Date: Thu, 23 Jan 2025 16:54:17 -0700 Subject: [PATCH] address input --- .../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 1c6b1af26..c3d7ac749 100644 --- a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala +++ b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala @@ -914,13 +914,13 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim */ def exprToProto( expr: Expression, - input: Seq[Attribute], + inputs: Seq[Attribute], binding: Boolean = true): Option[Expr] = { val conf = SQLConf.get val newExpr = DecimalPrecision.promote(conf.decimalOperationsAllowPrecisionLoss, expr, !conf.ansiEnabled) - exprToProtoInternal(newExpr, input, binding) + exprToProtoInternal(newExpr, inputs, binding) } def exprToProtoInternal(