[FLINK-3505] JoinUnionTransposeRule fails to push Join past Union.

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Resolved
• Fix Version/s: 1.1.0
• Component/s: Table SQL / API
• Assignee: Unassigned
• Reporter: Chengxiang Li
• Created: 25/Feb/16 03:33
• Updated: 16/Mar/16 15:10
• Resolved: 16/Mar/16 15:10

Description

val unionDs = ds1
      .unionAll(ds2.select('a, 'b, 'c))
      .join(ds3)
      .where('a === 'k)
      .select('a, 'b, 'l)

For this query, JoinUnionTransposeRule fails to push push Join past Union.

Issue Links

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