[FLINK-3506] ReduceExpressionsRule does not remove duplicate expression in Filter

• 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: 25/Feb/16 06:08
• Updated: 15/Mar/16 22:45
• Resolved: 15/Mar/16 22:45

Description

val ds = CollectionDataSets.get3TupleDataSet(env).as('a, 'b, 'c)
val filterDs = ds.filter('a % 2 !== 0).filter('b % 2 === 0).filter('a % 2 !== 0)

According to the ReduceExpressionsRule definition, we expect the duplicted filter expression get removed, while it's not after logical optimization.

Issue Links

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