flink sql ddl 不支持primary key

[叶贤勋]

Hi all:
    我看源码在将sqlNode转换CreateTableOperator[1]时，还是不支持primary key配置，但是sql parser是已经能够解析，请问下为何不放开这个限制。


https://github.com/apache/flink/blob/master/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java#L178




| |
叶贤勋
|
|
[hidden email]
|
签名由网易邮箱大师定制

[Jingsong Li]

Hi,

是的，现在是不支持，老的sink没有使用这个primary key来做upsert，但是在1.11里新的sink接口会打通DDL的primary
key的。[1]

[1]https://issues.apache.org/jira/browse/FLINK-17030

Best,
Jingsong Lee

On Tue, Apr 14, 2020 at 5:38 PM 叶贤勋 <[hidden email]> wrote:

> Hi all:
>     我看源码在将sqlNode转换CreateTableOperator[1]时，还是不支持primary key配置，但是sql
> parser是已经能够解析，请问下为何不放开这个限制。
>
>
>
> https://github.com/apache/flink/blob/master/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java#L178
>
>
>
>
> | |
> 叶贤勋
> |
> |
> [hidden email]
> |
> 签名由网易邮箱大师定制
>
>

--
Best, Jingsong Lee