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 叶贤勋 <yxx_c...@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_c...@163.com > | > 签名由网易邮箱大师定制 > > -- Best, Jingsong Lee