[FLINK-3503] ProjectJoinTransposeRule fails to push down project.

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Component/s: Table SQL / API
• Assignee: Fabian Hueske
• Reporter: Chengxiang Li
• Created: 25/Feb/16 03:00
• Updated: 16/Mar/16 14:44
• Resolved: 16/Mar/16 14:38

Description

    val ds1 = CollectionDataSets.getSmall3TupleDataSet(env).as('a, 'b, 'c)
    val ds2 = CollectionDataSets.get5TupleDataSet(env).as('d, 'e, 'f, 'g, 'h)

    val joinT = ds1.join(ds2).where('b === 'e).select('c, 'g)

For this query, ProjectJoinTransposeRule should pushes a Project past a Join by splitting the projection into a projection on top of each child of the join.

Issue Links

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