[ https://issues.apache.org/jira/browse/FLINK-21225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu updated FLINK-21225: ---------------------------- Fix Version/s: 1.12.3 1.13.0 > OverConvertRule does not consider distinct > ------------------------------------------ > > Key: FLINK-21225 > URL: https://issues.apache.org/jira/browse/FLINK-21225 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner > Reporter: Timo Walther > Assignee: Jane Chan > Priority: Major > Labels: pull-request-available > Fix For: 1.13.0, 1.12.3 > > > We don't support OVER window distinct aggregates in Table API. Even though > this is explicitly documented: > https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/tableApi.html#aggregations > {code} > // Distinct aggregation on over window > Table result = orders > .window(Over > .partitionBy($("a")) > .orderBy($("rowtime")) > .preceding(UNBOUNDED_RANGE) > .as("w")) > .select( > $("a"), $("b").avg().distinct().over($("w")), > $("b").max().over($("w")), > $("b").min().over($("w")) > ); > {code} > The distinct flag is set to false in {{OverConvertRule}}. > See also > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Unknown-call-expression-avg-amount-when-use-distinct-in-Flink-Thanks-td40905.html -- This message was sent by Atlassian Jira (v8.3.4#803005)