andygrove commented on issue #1238:
URL: 
https://github.com/apache/datafusion-comet/issues/1238#issuecomment-2580008932

   Query plan in `auto` mode passes because we fall back to Spark for most of 
the query:
   
   ```
   AdaptiveSparkPlan isFinalPlan=false
   +- CometSort [uid#7, count(DISTINCT score)#12L], [uid#7 ASC NULLS FIRST]
      +- CometColumnarExchange rangepartitioning(uid#7 ASC NULLS FIRST, 10), 
ENSURE_REQUIREMENTS, CometColumnarShuffle, [plan_id=528]
         +- HashAggregate(keys=[uid#7], functions=[count(distinct score#56)], 
output=[uid#7, count(DISTINCT score)#12L])
            +- Exchange hashpartitioning(uid#7, 10), ENSURE_REQUIREMENTS, 
[plan_id=523]
               +- HashAggregate(keys=[uid#7], functions=[partial_count(distinct 
score#56)], output=[uid#7, count#59L])
                  +- HashAggregate(keys=[uid#7, score#56], functions=[], 
output=[uid#7, score#56])
                     +- Exchange hashpartitioning(uid#7, score#56, 10), 
ENSURE_REQUIREMENTS, [plan_id=519]
                        +- HashAggregate(keys=[uid#7, 
knownfloatingpointnormalized(normalizenanandzero(score#8)) AS score#56], 
functions=[], output=[uid#7, score#56])
                           +- LocalTableScan [uid#7, score#8]
   ```
   
   Query plan in `jvm` mode:
   
   ```
      CometSort [uid#7, count(DISTINCT score)#12L], [uid#7 ASC NULLS FIRST]
      +- CometColumnarExchange rangepartitioning(uid#7 ASC NULLS FIRST, 10), 
ENSURE_REQUIREMENTS, CometColumnarShuffle, [plan_id=190]
         +- !CometHashAggregate [uid#7, count#35L], Final, [uid#7], 
[count(distinct score#32)]
            +- CometColumnarExchange hashpartitioning(uid#7, 10), 
ENSURE_REQUIREMENTS, CometColumnarShuffle, [plan_id=188]
               +- !CometHashAggregate [uid#7, score#32], Partial, [uid#7], 
[partial_count(distinct score#32)]
                  +- CometHashAggregate [uid#7, score#32], [uid#7, score#32]
                     +- CometColumnarExchange hashpartitioning(uid#7, score#32, 
10), ENSURE_REQUIREMENTS, CometColumnarShuffle, [plan_id=163]
                        +- HashAggregate(keys=[uid#7, 
knownfloatingpointnormalized(normalizenanandzero(score#8)) AS score#32], 
functions=[], output=[uid#7, score#32])
                           +- LocalTableScan [uid#7, score#8]
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to