Timo Walther created FLINK-21225: ------------------------------------ Summary: 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
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)