Details
-
Sub-task
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
1.3.0
-
None
Description
We copy calcite's AggregateExpandDistinctAggregatesRule to Flink project, and do a quick fix to avoid some bad case mentioned in CALCITE-1558.
Should drop it and use calcite's AggregateExpandDistinctAggregatesRule when we upgrade to calcite 1.12(above)
Attachments
Issue Links
- is related to
-
FLINK-3475 DISTINCT aggregate function support for SQL queries
- Closed
- links to