[FLINK-3487] FilterAggregateTransposeRule does not transform logical plan as desired.

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Component/s: Table SQL / API
• Assignee: Unassigned
• Reporter: Chengxiang Li
• Created: 24/Feb/16 06:50
• Updated: 16/Mar/16 15:12
• Resolved: 16/Mar/16 15:12

Description

val t = CollectionDataSets.get3TupleDataSet(env).as('a, 'b, 'c)
      .groupBy('a)
      .select('a, 'b.avg as 'value)
      .filter('a === 1)

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.

Issue Links

• relates to: FLINK-3508 Add more test cases to verify the rules of logical plan optimization