[FLINK-24033] Propagate unique keys for fromChangelogStream

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.13.2
• Fix Version/s: 1.14.0, 1.13.3, 1.15.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Release Note: Compared to 1.13.2, `StreamTableEnvironment.fromChangelogStream` might produce a different stream because primary keys were not properly considered before.
• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 27/Aug/21 14:21
• Updated: 31/Aug/21 15:23
• Resolved: 30/Aug/21 14:33

Description

Similar to FLINK-23915, we are not propagating unique keys for fromChangelogStream because it is not written into statistics.

Issue Links

• Discovered while testing: FLINK-23835 Test upsert sink with upsert keys
• links to: GitHub Pull Request #17048