[FLINK-27851] Join can't access the pk from source table

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.16.0
• Fix Version/s: 1.19.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available stale-assigned
• Assignee: xuyang
• Reporter: xuyang
• Created: 31/May/22 08:07
• Updated: 27/Dec/23 14:55
• Resolved: 27/Dec/23 14:55

Description

If the source table contains a pk and enable mini-batch, the join can't get the pk information in source table. The root cause is that the `FlinkRelMdUniqueKeys` is not override the function with arg MiniBatchAssigner.

Issue Links

• is duplicated by: FLINK-20036 Join Has NoUniqueKey when using mini-batch
• links to: GitHub Pull Request #19850