chore: Remove legacy code for adding a cast to a coalesce (apache#790)

huaxingao · Aug 8, 2024 · b5dac93 · b5dac93
1 parent 457d9d1
commit b5dac93
Showing 1 changed file with 1 addition and 9 deletions.
diff --git a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
@@ -2167,15 +2167,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
 
         case a @ Coalesce(_) =>
           val exprChildren = a.children.map(exprToProtoInternal(_, inputs))
-          val childExpr = scalarExprToProto("coalesce", exprChildren: _*)
-          // TODO: Remove this once we have new DataFusion release which includes
-          // the fix: https://github.com/apache/arrow-datafusion/pull/9459
-          if (childExpr.isDefined) {
-            castToProto(None, a.dataType, childExpr, CometEvalMode.LEGACY)
-          } else {
-            withInfo(expr, a.children: _*)
-            None
-          }
+          scalarExprToProto("coalesce", exprChildren: _*)
 
         // With Spark 3.4, CharVarcharCodegenUtils.readSidePadding gets called to pad spaces for
         // char types.