Skip to content

Commit 31fa46f

Browse files
committed
feat: do not fallback to Spark for distincts
1 parent 3778f34 commit 31fa46f

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -558,12 +558,6 @@ object QueryPlanSerde extends Logging with CometExprShim {
558558
binding: Boolean,
559559
conf: SQLConf): Option[AggExpr] = {
560560

561-
if (aggExpr.isDistinct) {
562-
// https://github.com/apache/datafusion-comet/issues/1260
563-
withInfo(aggExpr, s"distinct aggregate not supported: $aggExpr")
564-
return None
565-
}
566-
567561
val fn = aggExpr.aggregateFunction
568562
val cometExpr = aggrSerdeMap.get(fn.getClass)
569563
cometExpr match {

0 commit comments

Comments
 (0)