Skip to content

Commit

Permalink
address input
Browse files Browse the repository at this point in the history
  • Loading branch information
andygrove committed Jan 23, 2025
1 parent 432c617 commit 2cd5f5f
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit 2cd5f5f

Please sign in to comment.