You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 叶贤勋 <yx...@163.com> on 2020/04/14 09:38:08 UTC

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




| |
叶贤勋
|
|
yxx_cmhd@163.com
|
签名由网易邮箱大师定制

Re: flink sql ddl 不支持primary key

Posted by Jingsong Li <ji...@gmail.com>.

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 叶贤勋 <yx...@163.com> 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
>
>
>
>
> | |
> 叶贤勋
> |
> |
> yxx_cmhd@163.com
> |
> 签名由网易邮箱大师定制
>
>

-- 
Best, Jingsong Lee