gabotechs commented on issue #19849:
URL: https://github.com/apache/datafusion/issues/19849#issuecomment-3759014256
I think the main issue is how a hash `RepartitionExec` disappeared right at
the top of the plan.
```
SortPreservingMergeExec: [channel@0 ASC, i_brand_id@1 ASC, i_class_id@2 ASC,
i_category_id@3 ASC], fetch=100,
SortExec: TopK(fetch=100), expr=[channel@0 ASC, i_brand_id@1 ASC,
i_class_id@2 ASC, i_category_id@3 ASC], preserve_partitioning=[true],
filter=[channel@0 IS NULL OR channel@0 < catalog OR channel@0 = catalog AND
(i_brand_id@1 IS NULL OR i_brand_id@1 < 5004001) OR channel@0 = catalog AND
i_brand_id@1 = 5004001 AND (i_class_id@2 IS NULL OR i_class_id@2 < 2) OR
channel@0 = catalog AND i_brand_id@1 = 5004001 AND i_class_id@2 = 2 AND
(i_category_id@3 IS NULL OR i_category_id@3 < 1)],
ProjectionExec: expr=[channel@0 as channel, i_brand_id@1 as i_brand_id,
i_class_id@2 as i_class_id, i_category_id@3 as i_category_id, sum(y.sales)@5 as
sum_sales, sum(y.number_sales)@6 as sum_number_sales],
AggregateExec: mode=FinalPartitioned, gby=[channel@0 as channel,
i_brand_id@1 as i_brand_id, i_class_id@2 as i_class_id, i_category_id@3 as
i_category_id, __grouping_id@4 as __grouping_id], aggr=[sum(y.sales),
sum(y.number_sales)],
- RepartitionExec: partitioning=Hash([channel@0, i_brand_id@1,
i_class_id@2, i_category_id@3, __grouping_id@4], 16), input_partitions=16,
AggregateExec: mode=Partial, gby=[(NULL as channel, NULL as
i_brand_id, NULL as i_class_id, NULL as i_category_id), (channel@0 as channel,
NULL as i_brand_id, NULL as i_class_id, NULL as i_category_id), (channel@0 as
channel, i_brand_id@1 as i_brand_id, NULL as i_class_id, NULL as
i_category_id), (channel@0 as channel, i_brand_id@1 as i_brand_id, i_class_id@2
as i_class_id, NULL as i_category_id), (channel@0 as channel, i_brand_id@1 as
i_brand_id, i_class_id@2 as i_class_id, i_category_id@3 as i_category_id)],
aggr=[sum(y.sales), sum(y.number_sales)],
```
--
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]
