Skip to content

Commit

Permalink
Update spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
andygrove authored Jul 15, 2024
1 parent 8c802c4 commit 0b2a9a4
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1703,9 +1703,9 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
optExprWithInfo(optExpr, expr, child)
}

/// The expression for `log` functions is defined as null on numbers less than or equal
/// to 0. This matches Spark and Hive behavior, where non positive values eval to null
/// instead of NaN or -Infinity
// The expression for `log` functions is defined as null on numbers less than or equal
// to 0. This matches Spark and Hive behavior, where non positive values eval to null
// instead of NaN or -Infinity
case Log(child) =>
val childExpr = exprToProtoInternal(nullIfNegative(child), inputs)
val optExpr = scalarExprToProto("ln", childExpr)
Expand Down

0 comments on commit 0b2a9a4

Please sign in to comment.