Update spark/src/main/scala/org/apache/comet/serde/misc.scala

andygrove · martin-g · web-flow · commit ccc2b3cf34b4 · 2025-11-18T13:00:05.000-07:00
Co-authored-by: Martin Grigorov &lt;martin-g@users.noreply.github.com&gt;
diff --git a/spark/src/main/scala/org/apache/comet/serde/misc.scala b/spark/src/main/scala/org/apache/comet/serde/misc.scala
@@ -61,7 +61,7 @@ object CometKnownFloatingPointNormalized
       return None
     }
     val ex = exprToProtoInternal(wrapped, inputs, binding)
-    ex.map { child =>
+    val optExpr = ex.map { child =>
       val builder = ExprOuterClass.NormalizeNaNAndZero
         .newBuilder()
         .setChild(child)

Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,7 @@ object CometKnownFloatingPointNormalized`
`61`	`61`	`return None`
`62`	`62`	`}`
`63`	`63`	`val ex = exprToProtoInternal(wrapped, inputs, binding)`
`64`		`- ex.map { child =>`
	`64`	`+ val optExpr = ex.map { child =>`
`65`	`65`	`val builder = ExprOuterClass.NormalizeNaNAndZero`
`66`	`66`	`.newBuilder()`
`67`	`67`	`.setChild(child)`