Timo Walther created FLINK-23920:
------------------------------------
Summary: SchemaTranslator looses primary key if schema is inferred
Key: FLINK-23920
URL: https://issues.apache.org/jira/browse/FLINK-23920
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Reporter: Timo Walther
Assignee: Timo Walther
Schema derivation with primary key does not work correctly as the primary key
is not propagated:
{code}
tableEnv.toChangelogStream(...,
Schema.newBuilder().primaryKey("key").build(),
ChangelogMode.upsert())
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)