[
https://issues.apache.org/jira/browse/FLINK-24116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408664#comment-17408664
]
Timo Walther commented on FLINK-24116:
--------------------------------------
Jark raised a good point. It should still be possible for bounded sources.
[~jark] correct me if I'm wrong but this is mostly about avoiding ever-growing
state in temporal tables, right? In theory, we don't need this check at all and
could trust the user.
> PRIMARY KEY declaration on insert-only table is not validated globally
> ----------------------------------------------------------------------
>
> Key: FLINK-24116
> URL: https://issues.apache.org/jira/browse/FLINK-24116
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Reporter: Timo Walther
> Priority: Major
>
> In the regular Kafka connector, we validate that a primary key is not defined
> on an insert-only table source:
> https://github.com/apache/flink/pull/13850/commits/c1d4dc89fa629e0f04102e7ab2fa94984cd98218
> However, this should be validated for every connector because it is confusing
> if it works for others. We should validate this in the planner instead.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
