[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827994#comment-15827994 ]
ASF GitHub Bot commented on FLINK-3475: --------------------------------------- Github user docete commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r96628698 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/FlinkRuleSets.scala --- @@ -96,6 +96,13 @@ object FlinkRuleSets { ProjectToCalcRule.INSTANCE, CalcMergeRule.INSTANCE, + // distinct aggregate rule for FLINK-3475 --- End diff -- Done. The tracking jira is https://issues.apache.org/jira/browse/FLINK-5545 > DISTINCT aggregate function support for SQL queries > --------------------------------------------------- > > Key: FLINK-3475 > URL: https://issues.apache.org/jira/browse/FLINK-3475 > Project: Flink > Issue Type: New Feature > Components: Table API & SQL > Reporter: Chengxiang Li > Assignee: Zhenghua Gao > > DISTINCT aggregate function may be able to reuse the aggregate function > instead of separate implementation, and let Flink runtime take care of > duplicate records. -- This message was sent by Atlassian JIRA (v6.3.4#6332)