[FLINK-21225] OverConvertRule does not consider distinct

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.2, 1.13.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Jane Chan
• Reporter: Timo Walther
• Created: 01/Feb/21 08:54
• Updated: 15/Feb/21 08:31
• Resolved: 10/Feb/21 05:14

Description

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

// 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"))
    );

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

Issue Links

• links to: GitHub Pull Request #14877
• links to: GitHub Pull Request #14917