[FLINK-23920] SchemaTranslator looses primary key if schema is inferred

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.14.0, 1.13.3
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 23/Aug/21 10:40
• Updated: 25/Aug/21 09:53
• Resolved: 25/Aug/21 09:53

Description

Schema derivation with primary key does not work correctly as the primary key is not propagated:

tableEnv.toChangelogStream(...,
    Schema.newBuilder().primaryKey("key").build(),
    ChangelogMode.upsert())

Issue Links

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