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 01534f196..0af593f6d 100644 --- a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala +++ b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala @@ -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)