lazy_coalesce_fallback_case_statement

coderfender · coderfender · commit f0055e344fff · 2025-09-01T13:57:29.000-07:00
diff --git a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
@@ -1079,8 +1079,8 @@ object QueryPlanSerde extends Logging with CometExprShim {
           None
         }
 
-//  DataFusion coalesce doesnt perform lazy evaluation. Falling back to CASE statement until upstream data fusion issue is fixed
-//  https://github.com/apache/datafusion/pull/17357/files
+//  DataFusion coalesce doesn't perform lazy evaluation. Falling back to CASE statement
+//  https://github.com/apache/datafusion/issues/17322
 
       case c @ (CaseWhen(_, _) | Coalesce(_)) =>
         val (finalBranches, finalElse) = c match {

Original file line number	Diff line number	Diff line change
`@@ -1079,8 +1079,8 @@ object QueryPlanSerde extends Logging with CometExprShim {`
`1079`	`1079`	`None`
`1080`	`1080`	`}`
`1081`	`1081`
`1082`		`-// DataFusion coalesce doesnt perform lazy evaluation. Falling back to CASE statement until upstream data fusion issue is fixed`
`1083`		`-// https://github.com/apache/datafusion/pull/17357/files`
	`1082`	`+// DataFusion coalesce doesn't perform lazy evaluation. Falling back to CASE statement`
	`1083`	`+// https://github.com/apache/datafusion/issues/17322`
`1084`	`1084`
`1085`	`1085`	`case c @ (CaseWhen(_, _) \| Coalesce(_)) =>`
`1086`	`1086`	`val (finalBranches, finalElse) = c match {`