Chengxiang Li created FLINK-3487: ------------------------------------ Summary: [SQL] FilterAggregateTransposeRule does not transform logical plan as desired. Key: FLINK-3487 URL: https://issues.apache.org/jira/browse/FLINK-3487 Project: Flink Issue Type: Bug Reporter: Chengxiang Li Priority: Minor
{noformat} val t = CollectionDataSets.get3TupleDataSet(env).as('a, 'b, 'c) .groupBy('a) .select('a, 'b.avg as 'value) .filter('a === 1) {noformat} For this query, filter is expected to be pushed down before the aggregate by FilterAggregateTransposeRule, currently the optimzied logical plan is not what we desired. -- This message was sent by Atlassian JIRA (v6.3.4#6332)